From 183475d55a4060624f3ba3b8c81fe9459c22c40b Mon Sep 17 00:00:00 2001 From: Judit Novak Date: Wed, 17 Dec 2025 12:50:54 +0100 Subject: [PATCH] [v3-1-test] [BUGFIX] Flush session() before processing Event Buffer (#59314) (cherry picked from commit e7a1e57fd16f7749f20d30f26b358af7bb01c8d5) Co-authored-by: Judit Novak --- task-sdk/src/airflow/sdk/definitions/dag.py | 2 ++ 1 file changed, 2 insertions(+) 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