Кто пользуется ExternalTaskSensor для установки зависимостей между дагами? Как вы свои задачи запускаете вне расписания? Если просто выполнить trigger_dag, по-идее сенсоры просто встанут на ожидание, т.к. даграна от которого зависит даг несуществует за заданную timedelta.
Привет коллеги!) разрешите вопрос: Имею dag с депендс он паст тру , кэтчап тру. Старт дата - два дня назад. , интервал @daily . Работает норм. Одна проблема - последний инстанс - не запускается хотя должен происходить сегодня
Пока такое чувство что вы думаете, что ваш execution_date за сегодня должен сегодня и сработать. Если нет - больше подробностей за какие execution_date были прогоны, и в какой момент времени даг включили.
Кто пользуется ExternalTaskSensor для установки зависимостей между дагами? Как вы свои задачи запускаете вне расписания? Если просто выполнить trigger_dag, по-идее сенсоры просто встанут на ожидание, т.к. даграна от которого зависит даг несуществует за заданную timedelta.
Подумал, что можно просто чистить даграны, которые по расписанию запускались) а действительно ли так надо делать?
Пока такое чувство что вы думаете, что ваш execution_date за сегодня должен сегодня и сработать. Если нет - больше подробностей за какие execution_date были прогоны, и в какой момент времени даг включили.
Вы правы) пункт 1 . Реально ожидаю что сегодня и должен, поскольку по старт дэйт плюс шедулер интервал как раз пройден
Вы правы) пункт 1 . Реально ожидаю что сегодня и должен, поскольку по старт дэйт плюс шедулер интервал как раз пройден
проникнитесь в суть execution_date условно если в 00:00 запускается даг, значит ваш последний дагран должен быть за вчера 00:00 (по execution_date естессно)
Привет коллеги!) разрешите вопрос: Имею dag с депендс он паст тру , кэтчап тру. Старт дата - два дня назад. , интервал @daily . Работает норм. Одна проблема - последний инстанс - не запускается хотя должен происходить сегодня
а оно всегда с лагом в день будет, если надо процессить данные сентября, то оно запустится, когда сентябрь кончится, т.е. 1 октября
проникнитесь в суть execution_date условно если в 00:00 запускается даг, значит ваш последний дагран должен быть за вчера 00:00 (по execution_date естессно)