https://dagster.io/ logo
#dagster-serverless
Title
# dagster-serverless
m

Manish Khatri

06/06/2023, 8:31 AM
Hi, we encountered a strange error on the dagster serverless infra side which prevented one of our jobs from completing. It was a temporary blip but I think it’s worth raising it just incase there’s a solution on your side that can help prevent it from happening in the future. The error came about after 2 ops were completed and just before the 3rd should have triggered: Event Type:
RUN_FAILURE
Error:
dagster_cloud_cli.core.errors.GraphQLStorageError
Trace stack in thread… ``````
Copy code
dagster_cloud_cli.core.errors.GraphQLStorageError: HTTPSConnectionPool(host='moo.agent.dagster.cloud', port=443): Read timed out. (read timeout=60)
  File "/usr/local/lib/python3.9/site-packages/dagster/_core/execution/api.py", line 988, in pipeline_execution_iterator
    for event in pipeline_context.executor.execute(pipeline_context, execution_plan):
  File "/usr/local/lib/python3.9/site-packages/dagster/_core/executor/multiprocess.py", line 240, in execute
    event_or_none = next(step_iter)
  File "/usr/local/lib/python3.9/site-packages/dagster/_core/executor/multiprocess.py", line 351, in execute_step_out_of_process
    yield DagsterEvent.step_worker_starting(
  File "/usr/local/lib/python3.9/site-packages/dagster/_core/events/__init__.py", line 1017, in step_worker_starting
    return DagsterEvent.from_step(
  File "/usr/local/lib/python3.9/site-packages/dagster/_core/events/__init__.py", line 413, in from_step
    log_step_event(step_context, event)
  File "/usr/local/lib/python3.9/site-packages/dagster/_core/events/__init__.py", line 292, in log_step_event
    step_context.log.log_dagster_event(
  File "/usr/local/lib/python3.9/site-packages/dagster/_core/log_manager.py", line 405, in log_dagster_event
    self.log(level=level, msg=msg, extra={DAGSTER_META_KEY: dagster_event})
  File "/usr/local/lib/python3.9/site-packages/dagster/_core/log_manager.py", line 420, in log
    self._log(level, msg, args, **kwargs)
  File "/usr/local/lib/python3.9/logging/__init__.py", line 1589, in _log
    self.handle(record)
  File "/usr/local/lib/python3.9/logging/__init__.py", line 1599, in handle
    self.callHandlers(record)
  File "/usr/local/lib/python3.9/logging/__init__.py", line 1661, in callHandlers
    hdlr.handle(record)
  File "/usr/local/lib/python3.9/logging/__init__.py", line 952, in handle
    self.emit(record)
  File "/usr/local/lib/python3.9/site-packages/dagster/_core/log_manager.py", line 286, in emit
    handler.handle(dagster_record)
  File "/usr/local/lib/python3.9/logging/__init__.py", line 952, in handle
    self.emit(record)
  File "/usr/local/lib/python3.9/site-packages/dagster/_core/instance/__init__.py", line 181, in emit
    self._instance.handle_new_event(event)
  File "/usr/local/lib/python3.9/site-packages/dagster/_core/instance/__init__.py", line 1783, in handle_new_event
    self._event_storage.store_event(event)
  File "/usr/local/lib/python3.9/site-packages/dagster_cloud/storage/event_logs/storage.py", line 374, in store_event
    self._execute_query(
  File "/usr/local/lib/python3.9/site-packages/dagster_cloud/storage/event_logs/storage.py", line 255, in _execute_query
    res = self._graphql_client.execute(
  File "/usr/local/lib/python3.9/site-packages/dagster_cloud_cli/core/graphql_client.py", line 126, in execute
    raise GraphQLStorageError(str(e)) from e
The above exception was caused by the following exception:
requests.exceptions.ReadTimeout: HTTPSConnectionPool(host='moo.agent.dagster.cloud', port=443): Read timed out. (read timeout=60)
  File "/usr/local/lib/python3.9/site-packages/dagster_cloud_cli/core/graphql_client.py", line 78, in execute
    return self._execute_retry(query, variable_values, headers)
  File "/usr/local/lib/python3.9/site-packages/dagster_cloud_cli/core/graphql_client.py", line 154, in _execute_retry
    response = <http://self._session.post|self._session.post>(
  File "/usr/local/lib/python3.9/site-packages/requests/sessions.py", line 637, in post
    return self.request("POST", url, data=data, json=json, **kwargs)
  File "/usr/local/lib/python3.9/site-packages/requests/sessions.py", line 589, in request
    resp = self.send(prep, **send_kwargs)
  File "/usr/local/lib/python3.9/site-packages/requests/sessions.py", line 703, in send
    r = adapter.send(request, **kwargs)
  File "/usr/local/lib/python3.9/site-packages/requests/adapters.py", line 532, in send
    raise ReadTimeout(e, request=request)
The above exception occurred during handling of the following exception:
urllib3.exceptions.ReadTimeoutError: HTTPSConnectionPool(host='moo.agent.dagster.cloud', port=443): Read timed out. (read timeout=60)
  File "/usr/local/lib/python3.9/site-packages/requests/adapters.py", line 486, in send
    resp = conn.urlopen(
  File "/usr/local/lib/python3.9/site-packages/urllib3/connectionpool.py", line 798, in urlopen
    retries = retries.increment(
  File "/usr/local/lib/python3.9/site-packages/urllib3/util/retry.py", line 550, in increment
    raise six.reraise(type(error), error, _stacktrace)
  File "/usr/local/lib/python3.9/site-packages/urllib3/packages/six.py", line 770, in reraise
    raise value
  File "/usr/local/lib/python3.9/site-packages/urllib3/connectionpool.py", line 714, in urlopen
    httplib_response = self._make_request(
  File "/usr/local/lib/python3.9/site-packages/urllib3/connectionpool.py", line 468, in _make_request
    self._raise_timeout(err=e, url=url, timeout_value=read_timeout)
  File "/usr/local/lib/python3.9/site-packages/urllib3/connectionpool.py", line 357, in _raise_timeout
    raise ReadTimeoutError(
The above exception occurred during handling of the following exception:
socket.timeout: The read operation timed out
  File "/usr/local/lib/python3.9/site-packages/urllib3/connectionpool.py", line 466, in _make_request
    six.raise_from(e, None)
  File "<string>", line 3, in raise_from
  File "/usr/local/lib/python3.9/site-packages/urllib3/connectionpool.py", line 461, in _make_request
    httplib_response = conn.getresponse()
  File "/usr/local/lib/python3.9/http/client.py", line 1377, in getresponse
    response.begin()
  File "/usr/local/lib/python3.9/http/client.py", line 320, in begin
    version, status, reason = self._read_status()
  File "/usr/local/lib/python3.9/http/client.py", line 281, in _read_status
    line = str(self.fp.readline(_MAXLINE + 1), "iso-8859-1")
  File "/usr/local/lib/python3.9/socket.py", line 704, in readinto
    return self._sock.recv_into(b)
  File "/usr/local/lib/python3.9/ssl.py", line 1242, in recv_into
    return self.read(nbytes, buffer)
  File "/usr/local/lib/python3.9/ssl.py", line 1100, in read
    return self._sslobj.read(len, buffer)
The above exception occurred during handling of the following exception:
TypeError: getresponse() got an unexpected keyword argument 'buffering'
  File "/usr/local/lib/python3.9/site-packages/urllib3/connectionpool.py", line 457, in _make_request
    httplib_response = conn.getresponse(buffering=True)
b

ben

06/06/2023, 7:24 PM
Hi Manish, thanks for the report - I’ll pass it along to the serverless team