diff --git a/airflow/jobs/scheduler_job_runner.py b/airflow/jobs/scheduler_job_runner.py index caecda1703f5b9..42a425ba812181 100644 --- a/airflow/jobs/scheduler_job_runner.py +++ b/airflow/jobs/scheduler_job_runner.py @@ -769,7 +769,7 @@ def _process_executor_events(self, session: Session) -> int: ) if info is not None: msg += " Extra info: %s" % info # noqa: RUF100, UP031, flynt - self._task_context_logger.error(msg, ti, state, ti.state, info, ti=ti) + self._task_context_logger.error(msg, ti=ti) # Get task from the Serialized DAG try: