dheerajturaga opened a new pull request, #54594: URL: https://github.com/apache/airflow/pull/54594
Tasks queued longer than task_queued_timeout were not being terminated by the Airflow scheduler, leading to accumulation of stale queued tasks over several days. Root Cause: The queued_by_job_id field was not being reset to None, which prevented the scheduler from recognizing that the task was eligible for termination due to timeout. Fix: Reset queued_by_job_id when rescheduling stuck tasks to ensure timeout monitoring works correctly across multiple DAG runs. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
