You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by rn...@apache.org on 2024/07/03 00:39:18 UTC

(airflow) branch main updated: Fix bug in `SchedulerJobRunner._process_executor_events` (#40563)

This is an automated email from the ASF dual-hosted git repository.

rnhttr pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new a8c4830d97 Fix bug in `SchedulerJobRunner._process_executor_events` (#40563)
a8c4830d97 is described below

commit a8c4830d9728e9e25d1164e124004eb42cda6e58
Author: Vincent <97...@users.noreply.github.com>
AuthorDate: Tue Jul 2 20:39:10 2024 -0400

    Fix bug in `SchedulerJobRunner._process_executor_events` (#40563)
---
 airflow/jobs/scheduler_job_runner.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/airflow/jobs/scheduler_job_runner.py b/airflow/jobs/scheduler_job_runner.py
index 61d6d7aecb..0ac822c7f2 100644
--- a/airflow/jobs/scheduler_job_runner.py
+++ b/airflow/jobs/scheduler_job_runner.py
@@ -780,7 +780,7 @@ class SchedulerJobRunner(BaseJobRunner, LoggingMixin):
                 )
                 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: