diff --git a/airflow-core/src/airflow/jobs/scheduler_job_runner.py b/airflow-core/src/airflow/jobs/scheduler_job_runner.py index fb6af1476c4eb..5b9fd70ea4cef 100644 --- a/airflow-core/src/airflow/jobs/scheduler_job_runner.py +++ b/airflow-core/src/airflow/jobs/scheduler_job_runner.py @@ -798,7 +798,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 = (