по счастливой случайности в поле овнер будет лежать значение совпадающее с тем кто является хозяином этого лог-эвента

Ааа, хозяин лог эвента ) ок, а я зацепился за название owner.

Дратути
Есть даг, который может периодически работать в несколько раз дольше, и не так критично, если 1-2 запуска будет пропущено. В старых версиях новые запуски создавались только после завершения активного запуска (max_active_runs=1, catchup=False, depends_on_past=False), но с последних версий (ориентировочно с 2.1.3) эйрплов стал в процессе работы дага создавать будущие даграны в статусе queued, и тем самым создавать очередь, которую не может нагнать. Можно ли какой-нибудь опцией включить поведение "как раньше"? Сходу ничего не нашел

depends_on_past=true ?

False

ну если я правильно понял, надо выставить true

новая настройка появилась

Хочется как раз per dag

пишите фича реквест)

Скажите, а что является плагином для Airflow? Кастомный оператор это плагин?

Кастомный оператор может быть объявлен и не в плагине, в целом в доке довольно подробное описание https://airflow.apache.org/docs/apache-airflow/stable/plugins.html
У плагинов, правда, есть (по крайней, мере для меня) один недостаток – добавить свой тип коннекшна можно только через написание провайдера

Не совсем понял, что за недостаток такой. Ты про хуки? И вроде через описание хука можно добавить. И вообще ты про провайдеры, похоже, пишешь :)

Можно задать любой conn_type, но чтобы он отображался в UI (и не сбрасывался на другой при редактировании в UI же) придётся делать провайдера

https://airflow.apache.org/docs/apache-airflow/stable/howto/connection.html#custom-connection-types вот тут про это как раз написано

Спасибо, прям то что нужно

Спам ныне процветает в чате.

@aniiid @sytkinmts @olin32e забаньте, пожалуйста

Народ, что я делаю не так? Активирую виртуальное окружение, инициализирую БД, запускаю вебсервер, запускаю scheduler. Всё это запускаю с &. Закрываю вкладку. И Даг не пашет. Scheduler отваливается

Еще такая ошибка появляется OSError: [Errno 5] Input/output error если попытаться почистить даг