davido912 opened a new issue #9638:
URL: https://github.com/apache/airflow/issues/9638
The Snowflake hook (and more accurately the dbapihook) logs sensitive
information that is retrieved from the Airflow connections metadata. This
happens by both the logger and the logging that comes with the cursor itself
that fires the SQL commands.
This part of the code I believe is the offender: (dbapi_hook.py/ run
function)
` with closing(conn.cursor()) as cur:
for s in sql:
if sys.version_info[0] < 3:
s = s.encode('utf-8')
if parameters is not None:
self.log.info("{} with parameters {}".format(s,
parameters))
cur.execute(s, parameters)
else:
self.log.info(s)
cur.execute(s)
`
I posted this issue on the official Slack channel and I was told to bring
this issue up here. Would be great if we could mask this kind of information
from being printed to the logs.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
