diff --git a/airflow/sensors/smart_sensor.py b/airflow/sensors/smart_sensor.py index 3df7313c05e6eb..4e7a6070027450 100644 --- a/airflow/sensors/smart_sensor.py +++ b/airflow/sensors/smart_sensor.py @@ -106,11 +106,18 @@ def create_new_task_handler(): Create task log handler for a sensor work. :return: log handler """ + from airflow.utils.log.secrets_masker import _secrets_masker # noqa + handler_config_copy = {k: handler_config[k] for k in handler_config} + del handler_config_copy['filters'] + formatter_config_copy = {k: formatter_config[k] for k in formatter_config} handler = dictConfigurator.configure_handler(handler_config_copy) formatter = dictConfigurator.configure_formatter(formatter_config_copy) handler.setFormatter(formatter) + + # We want to share the _global_ filterer instance, not create a new one + handler.addFilter(_secrets_masker()) return handler def _get_sensor_logger(self, si):