kazanzhy commented on code in PR #27514:
URL: https://github.com/apache/airflow/pull/27514#discussion_r1016010092
##########
airflow/providers/common/sql/hooks/sql.py:
##########
@@ -264,6 +266,7 @@ def run(
results = []
for sql_statement in sql:
self._run_command(cur, sql_statement, parameters)
+ self._update_query_ids(cur)
Review Comment:
It's an implementation that was before.
For Snowflake, you could it in this PR but for Trino it was deleted by me in
this PR
https://github.com/apache/airflow/commit/df00436569bb6fb79ce8c0b7ca71dddf02b854ef#diff-9a702240b5127432b36cea027e9846f74943e8c20c292f4301c182c6063db880
In both cases queryId was extracted after the `execute` and before the
handler was applied to the cursor
--
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]
