tirkarthi commented on code in PR #59470:
URL: https://github.com/apache/airflow/pull/59470#discussion_r2620256433
##########
providers/snowflake/src/airflow/providers/snowflake/triggers/snowflake_trigger.py:
##########
@@ -68,11 +68,6 @@ def serialize(self) -> tuple[str, dict[str, Any]]:
async def run(self) -> AsyncIterator[TriggerEvent]:
"""Wait for the query the snowflake query to complete."""
- SnowflakeSqlApiHook(
Review Comment:
I have less experience with Snowflake but the issue seems to be not about
the hook created here since run is called once and more about the hook created
here not used in `self.get_query_status`. The method `get_query_status` could
reuse the hook instead and recreate it only when the token becomes invalid.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
