This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch v2-10-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v2-10-test by this push:
new 3b9935e780 Add backcompat check for executors that don't inherit
BaseExecutor (#41906) (#41927)
3b9935e780 is described below
commit 3b9935e780ecfd55254d4363b5556ba24e02b937
Author: Jarek Potiuk <[email protected]>
AuthorDate: Sun Sep 1 16:32:55 2024 +0200
Add backcompat check for executors that don't inherit BaseExecutor (#41906)
(#41927)
(cherry picked from commit f168d0aedbc73b86b1bb0e7fb38cad4ce5a66621)
Co-authored-by: Daniel Standish
<[email protected]>
---
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 ba5f90c68b..69789e9df9 100644
--- a/airflow/jobs/scheduler_job_runner.py
+++ b/airflow/jobs/scheduler_job_runner.py
@@ -1135,6 +1135,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:
