OI
обычно execution_date - это текущая дата минус schedule_interval
Size: a a a
2018 March 22
OI
Т.е. если schedule_interval 1 день, то сегодня в полночь даг запустится за 21е число
OI
И он выполнится.
OI
Более того, вы можете запустить даг за какой-нибудь execution_date в прошлом (20, 19 и т.п.)
OI
Ну смотря для каких целей) вам просто нужно, чтобы execution_date был другой? Если да, то, возможно придется править исходники. Я ошибся, как параметр он вроде как не задается.
OI
ну тут, мне кажется, не в execution_date дело
у airflow где-то в документации даже было написано, что execution_date всегда немого из прошлого.
Мб у вас проблема с шедулером?
у airflow где-то в документации даже было написано, что execution_date всегда немого из прошлого.
Мб у вас проблема с шедулером?
OI
у нас все execution_date при schedule_interval='@daily' по сути "за вчера".
OI
SS
celery/worker на другой машине?
SS
что-то есть интересного в логах шедулера?
SS
думаю, что шедулер не может отправить таск на выполнение в celery
какая-нибудь бяка между мессадж-брокером и целери
какая-нибудь бяка между мессадж-брокером и целери
YE
Каждый раз когда таски или не запускаются, или не переходят из очереди в ранинг, в логах шедуллера масса всего интересного что может помочь разрешить проблему