Passing external_task_group_id to WorkflowTrigger (#39617)

apache · May 14, 2024 · 7db851f · 7db851f
1 parent 6bcec90
commit 7db851f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/airflow/sensors/external_task.py b/airflow/sensors/external_task.py
@@ -351,6 +351,7 @@ def execute(self, context: Context) -> None:
                 timeout=self.execution_timeout,
                 trigger=WorkflowTrigger(
                     external_dag_id=self.external_dag_id,
+                    external_task_group_id=self.external_task_group_id,
                     external_task_ids=self.external_task_ids,
                     execution_dates=self._get_dttm_filter(context),
                     allowed_states=self.allowed_states,