FileSensor¶

Use the FileSensor to detect files appearing your local filesystem. You need to have connection defined to use it (pass connection id via fs_conn_id). Default connection is fs_default.

airflow/example_dags/example_sensors.py[source]

t6 = FileSensor(task_id="wait_for_file", filepath="/tmp/temporary_file_for_testing")