From 4ade01473c95536c1849e198fdaadc7e31911f5a Mon Sep 17 00:00:00 2001 From: Kimyen Ladia Date: Wed, 13 Jul 2022 21:51:28 -0700 Subject: [PATCH] pass along the backfill command pool to the ti --- airflow/jobs/backfill_job.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/airflow/jobs/backfill_job.py b/airflow/jobs/backfill_job.py index 027e2c4915395..b1734c6d5ebe1 100644 --- a/airflow/jobs/backfill_job.py +++ b/airflow/jobs/backfill_job.py @@ -535,6 +535,9 @@ def _per_task_process(key, ti, session=None): # pylint: disable=too-many-return ): cfg_path = tmp_configuration_copy() + # pass along the backfill command pool arg to the ti + if self.pool: + ti.pool = self.pool executor.queue_task_instance( ti, mark_success=self.mark_success,