From 468d1846eefe703578cf6ce84ed345d248770172 Mon Sep 17 00:00:00 2001
From: Andrew Halpern <57367683+adh-wonolo@users.noreply.github.com>
Date: Fri, 23 Jun 2023 11:43:30 -0400
Subject: [PATCH] Fix backfill_job_runner to work with custom executors

---
 airflow/jobs/backfill_job_runner.py | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

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()