AirFlow - ограничение на выполнение c оператора DAG один раз в день - PullRequest
0 голосов
/ 13 июля 2020

У меня есть DAG, который запускается 3 раза в день, скажем, с операторами A, B и C: Пример потока DAG

Я хочу ограничить запуск оператора B только один раз в день, но в рамках DAG run. Допустим, при первом запланированном запуске DAG. Если этот оператор уже был выполнен сегодня, он пропустит этот оператор и пометит его как выполненный.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...