diff --git a/dagger/dag_creator/airflow/dag_creator.py b/dagger/dag_creator/airflow/dag_creator.py
index ff5f5e1..b22ff24 100644
--- a/dagger/dag_creator/airflow/dag_creator.py
+++ b/dagger/dag_creator/airflow/dag_creator.py
@@ -65,7 +65,10 @@ def _get_external_task_sensor(self, from_task_id: str, to_task_id: str) -> Exter
         from_pipeline_schedule = self._task_graph.get_node(from_task_id).obj.pipeline.schedule
         to_pipeline_schedule = self._task_graph.get_node(to_task_id).obj.pipeline.schedule
 
+        to_pipe_id = self._task_graph.get_node(to_task_id).obj.pipeline.name
+
         return ExternalTaskSensor(
+            dag=self._dags[to_pipe_id],
             task_id=external_sensor_name,
             external_dag_id=from_pipeline_name,
             external_task_id=from_task_name,