diff --git a/airflow-core/src/airflow/jobs/scheduler_job_runner.py b/airflow-core/src/airflow/jobs/scheduler_job_runner.py index 85d743a12301c..6e5011e8685c4 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 @@ def _reschedule_stuck_task(self, ti: TaskInstance, session: Session): .values( state=TaskInstanceState.SCHEDULED, queued_dttm=None, + queued_by_job_id=None, scheduled_dttm=timezone.utcnow(), ) .execution_options(synchronize_session=False)