(airflow) branch v2-10-test updated: Add backcompat check for executors that don't inherit BaseExecutor (#41906) (#41927)

[po...@apache.org]

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 <ja...@potiuk.com>
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 <15...@users.noreply.github.com>
---
 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: