Skip to content

Commit

Permalink
Add backcompat check for executors that don't inherit BaseExecutor (a…
Browse files Browse the repository at this point in the history
…pache#41906) (apache#41927)

(cherry picked from commit f168d0a)

Co-authored-by: Daniel Standish <15932138+dstandish@users.noreply.github.com>
  • Loading branch information
potiuk and dstandish authored Sep 1, 2024
1 parent eefdfe3 commit 3b9935e
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions airflow/jobs/scheduler_job_runner.py
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down

0 comments on commit 3b9935e

Please sign in to comment.