changing FleSensor filepath

interTwin-eu · Apr 6, 2024 · 2860c73 · 2860c73
1 parent 38fed40
commit 2860c73
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/dags_airflow_ale_fsensor_exmp.py b/dags_airflow_ale_fsensor_exmp.py
@@ -19,12 +19,14 @@
     default_args={"depends_on_past": True},
 )
 
+
+
 create_metrics = DummyOperator(task_id="create_metrics", dag=dag)
 
 for f_id in [1, 2, 3]:
     wait = FileSensor(
         task_id=f"wait_for_file_{f_id}",
-        filepath=f"/data/f_{f_id}/data.csv",
+        filepath=f"/tmp/f_{f_id}/data.csv",
         dag=dag,
     )
     copy = DummyOperator(task_id=f"copy_f_{f_id}", dag=dag)