You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Describe the bug
In Airflow 2.7.1, it appears that the SnowflakeOperator is not renewing it's token when deferred, causing the task to fail to resume.
To Reproduce
Steps to reproduce the behavior:
Defer a Snowflake Sensor for an extended period of time.
Expected behavior
Token should renew, similar to how the AWSBaseHook does (#1292)
Screenshots [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'
Desktop (please complete the following information):
Astro Runtime 9.1.0
The text was updated successfully, but these errors were encountered:
Describe the bug
In Airflow 2.7.1, it appears that the SnowflakeOperator is not renewing it's token when deferred, causing the task to fail to resume.
To Reproduce
Steps to reproduce the behavior:
Defer a Snowflake Sensor for an extended period of time.
Expected behavior
Token should renew, similar to how the AWSBaseHook does (#1292)
Screenshots
[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'
Desktop (please complete the following information):
Astro Runtime 9.1.0
The text was updated successfully, but these errors were encountered: