diff --git a/airflow/jobs/backfill_job_runner.py b/airflow/jobs/backfill_job_runner.py index 40c31c4451fa5..8d8840bf502cb 100644 --- a/airflow/jobs/backfill_job_runner.py +++ b/airflow/jobs/backfill_job_runner.py @@ -540,9 +540,7 @@ def _per_task_process(key, ti: TaskInstance, session): cfg_path = None - executor_class, _ = ExecutorLoader.import_executor_cls( - self.job.executor_class, - ) + executor_class = self.job.executor.__class__ if executor_class.is_local: cfg_path = tmp_configuration_copy()