jonathanleek commented on issue #34968:
URL: https://github.com/apache/airflow/issues/34968#issuecomment-1764587048
`[2023-09-26T13:10:00.446+0000] {snowflake.py:219} INFO - Task deferred
[2023-09-26T13:10:00.453+0000] {taskinstance.py:1524} INFO - Pausing task as
DEFERRED. dag_id=*****, task_id=*******, execution_date=20230925T080000,
start_date=20230926T130958`
When it resumed 5 minutes later it failed
`[2023-09-26T13:15:29.054+0000] {taskinstance.py:1935} ERROR - Task failed
with exception
Traceback (most recent call last):
File
"/usr/local/lib/python3.11/site-packages/airflow/models/baseoperator.py", line
1608, in resume_execution
return execute_callable(context)
^^^^^^^^^^^^^^^^^^^^^^^^^
File
"/usr/local/lib/python3.11/site-packages/astronomer/providers/snowflake/operators/snowflake.py",
line 242, in execute_complete
msg = f"sfquid: {event['query_id']}, {event['type']}: {event['message']}"
~~~~~^^^^^^^^^^^^
KeyError: 'query_id'`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@airflow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
