`airflow.contrib.sensors.file_sensor`¶

Module Contents¶

class airflow.contrib.sensors.file_sensor.FileSensor(filepath, fs_conn_id='fs_default', *args, **kwargs)[source]¶

Bases: airflow.sensors.base_sensor_operator.BaseSensorOperator

Waits for a file or folder to land in a filesystem.

If the path given is a directory then this sensor will only return true if any files exist inside it (either directly, or within a subdirectory)

Parameters

fs_conn_id (str) – reference to the File (path) connection id
filepath – File or folder name (relative to the base path set within the connection)

template_fields = ['filepath'][source]¶

ui_color = #91818a[source]¶

poke(self, context)[source]¶

Was this entry helpful?