Коллеги, доброе утро.
Дописал полный даг, полную цепочку алгоритма.
НА данный момент нужно сделать периодичесикй запуск на проверку файлов на бакете, если все ок то запускается даг, если нет, то будет отдыхать.

Подскажите куда копать насчет периодечкого запуска

А по реализации на данный момент, функционал по проверке файлов на бакете есть в самом даге, то есть если файл нашелся то записываем его в таблицу соответсвующую и идет далее выполнять все блоки функционала независимо будут новые файлы или нет. Есть люди, кто такую штуку реализовывал?

ShortCircuitOperator лучше подходит, не?

Лично мне удобнее с бранчем, потому что часто хочется просто найти историю пустых запусков

Я пока просто немного не догоняю, решил сделать ветвление.

Понимаю что нужно в бранче вернуть таск или список тасков, но как они будут зависимы друг от друга?
То есть мне нужна та последовательность, которую я посторил в даге.

Или же построить какой-нибудь if блок, который будет возвращать таск - заглушку?

есть пример с бранчем?

В бранче возвращается название downstream таски к которой надо перейти

А, то есть если у меня есть список тасков, то он по идее должен так же запускать их асинхронно?

раз тут зашёл разговор про логи
нужно подружить airflow и graylog, кто-то сталкивался с таким? думаю, что раз у меня воркеры и план плащик крутятся в докер контейнерах, может писать из лол не в файл, а в stdin и забирать из как-то

Привет, настроил airflow под proxy сервером nginx, сделал path /airflow/ , но во время перехода airflow редиректит меня в /home это адрес уже другого приложения, как сделать чтобы редирект происходил в /airflow/home?