A sensor is a type of operator that waits for a condition to be met before letting the rest run: a file arriving, a partition being present, another DAG finishing, a given time. It polls periodically and fails after a maximum delay (timeout).
Example
FileSensor(task_id='attendre_fichier', filepath='/data/ventes.csv', poke_interval=60, timeout=3600)