diff --git a/airflow/utils/log/secrets_masker.py b/airflow/utils/log/secrets_masker.py index cac82d0dd12e2..6703139a3bc8e 100644 --- a/airflow/utils/log/secrets_masker.py +++ b/airflow/utils/log/secrets_masker.py @@ -207,7 +207,9 @@ def filter(self, record) -> bool: return True - def _redact_all(self, item: Redactable, depth: int, max_depth: int) -> Redacted: + # Default on `max_depth` is to support versions of the OpenLineage plugin (not the provider) which called + # this function directly. New versions of that provider, and this class itself call it with a value + def _redact_all(self, item: Redactable, depth: int, max_depth: int = MAX_RECURSION_DEPTH) -> Redacted: if depth > max_depth or isinstance(item, str): return "***" if isinstance(item, dict):