diff --git a/airflow/hooks/base.py b/airflow/hooks/base.py index f286a6f2ce3d3..3531bf3800d0b 100644 --- a/airflow/hooks/base.py +++ b/airflow/hooks/base.py @@ -22,6 +22,7 @@ from airflow.typing_compat import Protocol from airflow.utils.log.logging_mixin import LoggingMixin +from airflow.utils.log.secrets_masker import redact if TYPE_CHECKING: from airflow.models.connection import Connection # Avoid circular imports. @@ -74,8 +75,8 @@ def get_connection(cls, conn_id: str) -> "Connection": conn.port, conn.schema, conn.login, - conn.password, - conn.extra_dejson, + redact(conn.password), + redact(conn.extra_dejson), ) return conn