Filesystem Sensor Async¶
To waits asynchronously for a file or folder to land in a filesystem
FileSensorAsync
.
file_sensor_task = FileSensorAsync(
task_id="file_sensor_task",
filepath="example_file_async_sensor.txt",
fs_conn_id=FS_CONN_ID,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/core/example_dags/example_file_sensor.py