eladkal commented on a change in pull request #16676:
URL: https://github.com/apache/airflow/pull/16676#discussion_r659205722
##########
File path: airflow/hooks/dbapi.py
##########
@@ -211,8 +211,13 @@ def _run_command(self, cur, sql_statement, parameters):
self.log.info("Running statement: %s, parameters: %s", sql_statement,
parameters)
if parameters:
cur.execute(sql_statement, parameters)
+ res = cur.fetchall()
+ result={'sql_statement': res,'headers': list(map(lambda t: t[0],
cur.description))}
+ self.log.info("Query Results: %s", result)
Review comment:
I'm ok with the debug. my issue is mostly with the `fetchall`
It's important to remember that debug isn't for a specific dag - it's
cluster wide setting so when you set debug other DAGs log may get really big
but I guess that depends how each organization works.
--
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]
