diff --git a/airflow/jobs/scheduler_job_runner.py b/airflow/jobs/scheduler_job_runner.py index 61d6d7aecb62f..0ac822c7f232f 100644 --- a/airflow/jobs/scheduler_job_runner.py +++ b/airflow/jobs/scheduler_job_runner.py @@ -780,7 +780,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: