Блог

Я действительно новичок в Airflow, поэтому мне нужны некоторые предложения о том, как структурировать свой сценарий. Моя работа должна выполняться каждый месяц в последние два дня. Поэтому, если он будет запущен в декабре, задание будет выполнено 30 и 31 декабря, по пару раз в день. Есть ли способ, с помощью которого в моем сценарии я могу проверить, что конкретный идентификатор задачи определенной группы поддержки в течение текущего месяца был успешно выполнен в одном из предыдущих запусков? В основном я хотел бы выбрать запуски для dag в текущем месяце, а затем в выбранных dugs выяснить, был ли успешно выполнен интересующий меня task_id в одном из этих запусков.

Оглядевшись, я нашел этот модуль, который мог бы мне помочь, но я не знаю, как выбрать только dag, выполненные в текущем месяце.

dag_run = DagRun.найти(dag_id=’dag_id’, дата исполнения=?)

Кроме того, я не знаю, как выполнять поиск этих запусков в течение месяца в поисках успешного идентификатора задачи. Кто-нибудь может дать мне несколько советов по этому поводу?