Size: a a a

2020 September 29

NP

N P in Airflow
Наверняка ктото сталкивался
источник

ДН

Дмитрий Негреев... in Airflow
Кто пользуется ExternalTaskSensor для установки зависимостей между дагами?
Как вы свои задачи запускаете вне расписания?
Если просто выполнить trigger_dag, по-идее сенсоры просто встанут на ожидание, т.к. даграна от которого зависит даг несуществует за заданную timedelta.
источник

ДН

Дмитрий Негреев... in Airflow
N P
Привет коллеги!) разрешите вопрос:
Имею dag с депендс он паст тру ,  кэтчап тру. Старт дата - два дня назад. , интервал @daily .  Работает норм. Одна проблема - последний инстанс - не запускается хотя должен происходить сегодня
Пока такое чувство что вы думаете, что ваш execution_date за сегодня должен сегодня и сработать.
Если нет - больше подробностей за какие execution_date были прогоны, и в какой момент времени даг включили.
источник

ДН

Дмитрий Негреев... in Airflow
Дмитрий Негреев
Кто пользуется ExternalTaskSensor для установки зависимостей между дагами?
Как вы свои задачи запускаете вне расписания?
Если просто выполнить trigger_dag, по-идее сенсоры просто встанут на ожидание, т.к. даграна от которого зависит даг несуществует за заданную timedelta.
Подумал, что можно просто чистить даграны, которые по расписанию запускались)
а действительно ли так надо делать?
источник

NP

N P in Airflow
Дмитрий Негреев
Пока такое чувство что вы думаете, что ваш execution_date за сегодня должен сегодня и сработать.
Если нет - больше подробностей за какие execution_date были прогоны, и в какой момент времени даг включили.
Вы правы) пункт 1 .  Реально ожидаю что сегодня и должен,  поскольку по старт дэйт плюс шедулер интервал как раз пройден
источник

ДН

Дмитрий Негреев... in Airflow
N P
Вы правы) пункт 1 .  Реально ожидаю что сегодня и должен,  поскольку по старт дэйт плюс шедулер интервал как раз пройден
проникнитесь в суть execution_date
условно если в 00:00 запускается даг, значит ваш последний дагран должен быть за вчера 00:00 (по execution_date естессно)
источник

ME

Max Efremov in Airflow
N P
Привет коллеги!) разрешите вопрос:
Имею dag с депендс он паст тру ,  кэтчап тру. Старт дата - два дня назад. , интервал @daily .  Работает норм. Одна проблема - последний инстанс - не запускается хотя должен происходить сегодня
а оно всегда с лагом в день будет, если надо процессить данные сентября, то оно запустится, когда сентябрь кончится, т.е. 1 октября
источник

A

Anatole in Airflow
А вы пробовали передать так как там написано?
источник

A

Anatole in Airflow
Почему то надежнее кажется сделать makefile и скрипт для импорта прописанных в файле параметров но все равно спасибо буду пробовать и так и так
источник

NP

N P in Airflow
Дмитрий Негреев
проникнитесь в суть execution_date
условно если в 00:00 запускается даг, значит ваш последний дагран должен быть за вчера 00:00 (по execution_date естессно)
Учтя этот комментарий решил проблему, спасибо)
источник

AA

Anton Afonin in Airflow
Anatole
А вы пробовали передать так как там написано?
Нет, а к чему вопрос?)
источник

K

KrivdaTheTriewe in Airflow
Дагогенерация вперёд
источник

K

KrivdaTheTriewe in Airflow
По эирфлоу есть митапы в рф ?
источник

K

KrivdaTheTriewe in Airflow
Или что то крупное сча будет ?
источник

YL

Yevhenii Lukashov in Airflow
Или книги
источник

YL

Yevhenii Lukashov in Airflow
Есть книги по аирфлоу?
источник

K

KrivdaTheTriewe in Airflow
Книги не нужны
источник

K

KrivdaTheTriewe in Airflow
Yevhenii Lukashov
Есть книги по аирфлоу?
Дока
источник

K

KrivdaTheTriewe in Airflow
И отказаться от встроенных операторов
источник

YL

Yevhenii Lukashov in Airflow
Как написать свой?
источник