Correction to connection

interTwin-eu · Apr 6, 2024 · e6524a8 · e6524a8
1 parent 66f0c9d
commit e6524a8
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/dags_airflow_ale_fsensor_exmp.py b/dags_airflow_ale_fsensor_exmp.py
@@ -27,7 +27,10 @@
     wait = FileSensor(
         task_id=f"wait_for_file_{f_id}",
         fs_conn_id="temp_data",
-        filepath=f"f_{f_id}/data.csv",
+        filepath=f"d_{f_id}/data.csv",
+        poke_interval=10,
+        timeout=180,
+
         dag=dag,
     )
     copy = DummyOperator(task_id=f"copy_f_{f_id}", dag=dag)