(airflow) branch main updated: Fix task_queued_timeout not working after first DAG run (#54594)

[ash]

This is an automated email from the ASF dual-hosted git repository.

ash pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new bec069c161d Fix task_queued_timeout not working after first DAG run 
(#54594)
bec069c161d is described below

commit bec069c161d0d38e7b0f5c79312931cd34599f02
Author: Dheeraj Turaga <dheerajtur...@gmail.com>
AuthorDate: Mon Aug 18 03:35:37 2025 -0500

    Fix task_queued_timeout not working after first DAG run (#54594)
    
    Reset queued_by_job_id when rescheduling stuck tasks to ensure timeout
    monitoring works correctly across multiple DAG runs.
---
 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 85d743a1230..6e5011e8685 100644
--- a/airflow-core/src/airflow/jobs/scheduler_job_runner.py
+++ b/airflow-core/src/airflow/jobs/scheduler_job_runner.py
@@ -2055,6 +2055,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)