diff --git a/airflow-core/src/airflow/jobs/scheduler_job_runner.py b/airflow-core/src/airflow/jobs/scheduler_job_runner.py index 4c52a9ee0290b..12a71275e715e 100644 --- a/airflow-core/src/airflow/jobs/scheduler_job_runner.py +++ b/airflow-core/src/airflow/jobs/scheduler_job_runner.py @@ -1974,7 +1974,7 @@ def _maybe_requeue_stuck_ti(self, *, ti, session): """ num_times_stuck = self._get_num_times_stuck_in_queued(ti, session) if num_times_stuck < self._num_stuck_queued_retries: - self.log.info("Task stuck in queued; will try to requeue. task_id=%s", ti.task_id) + self.log.info("Task stuck in queued; will try to requeue. task_instance=%s", ti) session.add( Log( event=TASK_STUCK_IN_QUEUED_RESCHEDULE_EVENT,