Получить запланированное время для захвата = истина в потоке воздуха - PullRequest
0 голосов
/ 11 мая 2018

У меня есть dag, который по расписанию должен вызывать скрипт, ежедневно передавающий текущую дату, поэтому я передаю {{ds}} , чтобы получить дату выполнения.

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

Как я могу это сделать?

1 Ответ

0 голосов
/ 11 мая 2018

Насколько я понимаю ваш сценарий, execution_date - это именно то, что вам нужно.

Имя может вводить в заблуждение, но на самом деле оно заполнено запланированной отметкой времени.

...