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 <[email protected]>
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:
