Sensor — задача, которая ждёт внешнего условия (файл в S3, partition в Hive, сообщение, время) и успех/таймаут/reschedule, прежде чем пустить downstream.
Разбор
- Режимы
poke (держит worker slot) и reschedule (освобождает worker между проверками).
- Типично:
S3KeySensor, ExternalTaskSensor, SqlSensor.
- Долгий poke без reschedule забивает pool/worker.
- Timeout и soft_fail настраивают поведение при отсутствии события.
Итог
Sensor синхронизирует DAG с внешним событием; предпочитайте reschedule для долгих ожиданий.
