Tyrone Wong
05/25/2023, 11:14 PMOperation name: SingleJobQuery
Message: (psycopg2.errors.QueryCanceled) canceling statement due to statement timeout
[SQL: SELECT runs.id, runs.run_body, runs.status, runs.create_timestamp, runs.update_timestamp, runs.start_time, runs.end_time
FROM runs
WHERE runs.pipeline_name = %(pipeline_name_1)s AND runs.run_id IN (SELECT run_tags.run_id
FROM run_tags
WHERE run_tags.key = %(key_1)s AND run_tags.value = %(value_1)s) ORDER BY runs.id DESC
LIMIT %(param_1)s]
[parameters: {'pipeline_name_1': 'databricksScheduledJobsTrigger', 'key_1': '.dagster/repository', 'value_1': 'statscript@statscript', 'param_1': 5}]
(Background on this error at: <https://sqlalche.me/e/14/e3q8>)
Path: ["pipelineOrError","runs"]
Locations: [{"line":8,"column":7}]
Stack Trace:
File "/usr/local/lib/python3.7/site-packages/graphql/execution/execute.py", line 521, in execute_field
result = resolve_fn(source, info, **args)
File "/usr/local/lib/python3.7/site-packages/dagster_graphql/schema/pipelines/pipeline.py", line 904, in resolve_runs
return super().resolve_runs(graphene_info, cursor=cursor, limit=limit)
File "/usr/local/lib/python3.7/site-packages/dagster_graphql/schema/pipelines/pipeline.py", line 733, in resolve_runs
return get_runs(graphene_info, runs_filter, cursor, limit)
File "/usr/local/lib/python3.7/site-packages/dagster_graphql/implementation/fetch_runs.py", line 132, in get_runs
for record in instance.get_run_records(filters=filters, cursor=cursor, limit=limit)
File "/usr/local/lib/python3.7/site-packages/dagster/_utils/__init__.py", line 647, in inner
return func(*args, **kwargs)
File "/usr/local/lib/python3.7/site-packages/dagster/_core/instance/__init__.py", line 1597, in get_run_records
filters, limit, order_by, ascending, cursor, bucket_by
File "/usr/local/lib/python3.7/site-packages/dagster/_core/storage/runs/sql_run_storage.py", line 510, in get_run_records
rows = self.fetchall(query)
File "/usr/local/lib/python3.7/site-packages/dagster/_core/storage/runs/sql_run_storage.py", line 110, in fetchall
result_proxy = conn.execute(query)
File "/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/base.py", line 1380, in execute
return meth(self, multiparams, params, _EMPTY_EXECUTION_OPTS)
File "/usr/local/lib/python3.7/site-packages/sqlalchemy/sql/elements.py", line 335, in _execute_on_connection
self, multiparams, params, execution_options
File "/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/base.py", line 1582, in _execute_clauseelement
cache_hit=cache_hit,
File "/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/base.py", line 1944, in _execute_context
e, statement, parameters, cursor, context
File "/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/base.py", line 2125, in _handle_dbapi_exception
sqlalchemy_exception, with_traceback=exc_info[2], from_=e
File "/usr/local/lib/python3.7/site-packages/sqlalchemy/util/compat.py", line 211, in raise_
raise exception
File "/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/base.py", line 1901, in _execute_context
cursor, statement, parameters, context
File "/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/default.py", line 736, in do_execute
cursor.execute(statement, parameters)
The above exception was the direct cause of the following exception:
Message: psycopg2.errors.QueryCanceled: canceling statement due to statement timeout
Stack Trace:
File "/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/base.py", line 1901, in _execute_context
cursor, statement, parameters, context
File "/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/default.py", line 736, in do_execute
cursor.execute(statement, parameters)
owen
05/26/2023, 5:48 PM