potiuk edited a comment on issue #17604: URL: https://github.com/apache/airflow/issues/17604#issuecomment-898598673
OK. Thanks for the context. Really helpful. I think I know the problem, secret masker will not mask K8S env vars, it masks Airflow Variables. Maybe it is a good idea to add it then (should be possible - @ashb WDYT?). As a temporary workaround - you should be able to mask your variables "manually" (also to test if your logging configuration works). Following https://airflow.apache.org/docs/apache-airflow/stable/security/secrets/index.html#adding-your-own-masks you could derive a custom class from K8SPodExecutor and override it's `execute` method with something like: ``` def execute(self, context): from airflow.utils.log.secrets_masker import mask_secret mask_secret(sec["DBT_WAREHOUSE"]) return super.execute(context) ``` -- 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: commits-unsubscr...@airflow.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
