diff --git a/airflow/models/dag.py b/airflow/models/dag.py index ceb2ca2eb70a5..d28311369367b 100644 --- a/airflow/models/dag.py +++ b/airflow/models/dag.py @@ -2760,6 +2760,7 @@ def add_logger_if_needed(ti: TaskInstance): _run_task(ti, session=session) except Exception: self.log.exception("Task failed; ti=%s", ti) + raise if conn_file_path or variable_file_path: # Remove the local variables we have added to the secrets_backend_list secrets_backend_list.pop(0)