diff --git a/airflow-core/src/airflow/jobs/scheduler_job_runner.py b/airflow-core/src/airflow/jobs/scheduler_job_runner.py index 981117c073339..9d7fedbb50c25 100644 --- a/airflow-core/src/airflow/jobs/scheduler_job_runner.py +++ b/airflow-core/src/airflow/jobs/scheduler_job_runner.py @@ -866,7 +866,7 @@ def process_executor_events( if state in (TaskInstanceState.QUEUED, TaskInstanceState.RUNNING): ti.external_executor_id = info - cls.logger().info("Setting external_id for %s to %s", ti, info) + cls.logger().info("Setting external_executor_id for %s to %s", ti, info) continue msg = (