This is an automated email from the ASF dual-hosted git repository.
potiuk 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 f168d0aedb Add backcompat check for executors that don't inherit
BaseExecutor (#41906)
f168d0aedb is described below
commit f168d0aedbc73b86b1bb0e7fb38cad4ce5a66621
Author: Daniel Standish <[email protected]>
AuthorDate: Sun Sep 1 05:35:46 2024 -0700
Add backcompat check for executors that don't inherit BaseExecutor (#41906)
---
airflow/jobs/scheduler_job_runner.py | 3 +++
1 file changed, 3 insertions(+)
diff --git a/airflow/jobs/scheduler_job_runner.py
b/airflow/jobs/scheduler_job_runner.py
index f4f8fa43cd..9b817ecc25 100644
--- a/airflow/jobs/scheduler_job_runner.py
+++ b/airflow/jobs/scheduler_job_runner.py
@@ -1144,6 +1144,9 @@ class SchedulerJobRunner(BaseJobRunner, LoggingMixin):
for executor in self.job.executors:
try:
+ # this is backcompat check if executor does not
inherit from BaseExecutor
+ if not hasattr(executor, "_task_event_logs"):
+ continue
with create_session() as session:
self._process_task_event_logs(executor._task_event_logs, session)
except Exception:
