diff --git a/task-sdk/src/airflow/sdk/definitions/dag.py b/task-sdk/src/airflow/sdk/definitions/dag.py index d5ae8353bd93d..b51012d64a0fd 100644 --- a/task-sdk/src/airflow/sdk/definitions/dag.py +++ b/task-sdk/src/airflow/sdk/definitions/dag.py @@ -1339,6 +1339,8 @@ def test( log.exception("Task failed; ti=%s", ti) if use_executor: executor.heartbeat() + session.expire_all() + from airflow.jobs.scheduler_job_runner import SchedulerJobRunner from airflow.models.dagbag import DBDagBag