Add backcompat check for executors that don't inherit BaseExecutor (a…

…pache#41906) (apache#41927) (cherry picked from commit f168d0a) Co-authored-by: Daniel Standish <[email protected]>
aws-mwaa · Sep 1, 2024 · 3b9935e · 3b9935e
1 parent eefdfe3
commit 3b9935e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/airflow/jobs/scheduler_job_runner.py b/airflow/jobs/scheduler_job_runner.py
@@ -1135,6 +1135,9 @@ def _run_scheduler_loop(self) -> None:
 
                 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: