Совершенно новичок в Airflow, любопытно, есть ли у кого-нибудь предложения о том, как решить мою текущую задачу.
Мне в основном нужна задача из двух частей. Я написал Python для всего этого, но не уверен, как правильно Airflow-ify.
Часть 1, сканирует календарь на предмет запланированных изменений. -> Если найдено изменение для этого дня, запланируйте задачу на этот день / время (часть 2)
Часть 2, запланируйте задачу для внесения изменений, создайте некоторое подавление предупреждений, выполнитеизменить задачу, проверить вывод и пометить изменение как выполненное.
Я не совсем понимаю, как заставить часть 1 создавать задачи для части 2, а не создавать повторяющиеся задачи каждый раз, когда сканирование календаря завершается.