This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a commit to branch v3-0-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-0-test by this push:
new 9da77695562 [v3-0-test] Fix task_queued_timeout not working after
first DAG run (#54594) (#54604)
9da77695562 is described below
commit 9da77695562e95af17f3d07161b6ff82f6e3468f
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Aug 18 17:31:03 2025 +0100
[v3-0-test] Fix task_queued_timeout not working after first DAG run
(#54594) (#54604)
Reset queued_by_job_id when rescheduling stuck tasks to ensure timeout
monitoring works correctly across multiple DAG runs.
(cherry picked from commit bec069c161d0d38e7b0f5c79312931cd34599f02)
Co-authored-by: Dheeraj Turaga <[email protected]>
---
airflow-core/src/airflow/jobs/scheduler_job_runner.py | 1 +
1 file changed, 1 insertion(+)
diff --git a/airflow-core/src/airflow/jobs/scheduler_job_runner.py
b/airflow-core/src/airflow/jobs/scheduler_job_runner.py
index cd517af6b97..f093a3e3607 100644
--- a/airflow-core/src/airflow/jobs/scheduler_job_runner.py
+++ b/airflow-core/src/airflow/jobs/scheduler_job_runner.py
@@ -2103,6 +2103,7 @@ class SchedulerJobRunner(BaseJobRunner, LoggingMixin):
.values(
state=TaskInstanceState.SCHEDULED,
queued_dttm=None,
+ queued_by_job_id=None,
scheduled_dttm=timezone.utcnow(),
)
.execution_options(synchronize_session=False)
