Телеграмм чат группы ruairflow страница 1145

кто-нибудь свои плагины вызывает через
airflow.hooks.my_namespace.MyHook
airflow.operators.my_namespace.MyOperator?

упаковал плагин в колесо, и в даге импортирую просто как
my_plugin.operators.my_namespace.MyOperator
все работает вроде, и никаких ошибкок в IDE нет

источник

16:33пожаловаться #8

ДН

Дмитрий Негреев... in Airflow

есть какая-то разница?

источник

16:33пожаловаться #9

Nikita in Airflow

N P

А как?

Параметр max_active_runs у дага

источник

16:38пожаловаться #10

Alex in Airflow

Max Efremov

кстати, эта штука всегда на 1 минуте висит, не увеличивается через минуту...

а параметр scheduler_heartbeat_sec не трогали, случайно не 60?

источник

16:52пожаловаться #11

Max Efremov in Airflow

Alex

а параметр scheduler_heartbeat_sec не трогали, случайно не 60?

да, верно

источник

16:53пожаловаться #12

Alex in Airflow

тогда все в норме

источник

16:54пожаловаться #13

Max Efremov in Airflow

Наверное можно поставить 5 и убрать сообщение))

источник

16:54пожаловаться #14

Alex in Airflow

по гайдам на проде рекомендуют 60 ставить. Не понятно как это сообщение подправить чтобы оно учитывало этот параметр.

источник

16:55пожаловаться #15

Alex in Airflow

У меня тоже это сообщение показывается, может кто знает как его убрать не изменяя scheduler_heartbeat_sec? По логике, это сообщение нужно показывать когда Last heartbeat будет больше scheduler_heartbeat_sec

источник

16:57пожаловаться #16

Max Efremov in Airflow

Надо посмотреть код показа сообщения

источник

16:59пожаловаться #17

Max Efremov in Airflow

мб там что-то захардкоженное

источник

16:59пожаловаться #18

Max Efremov in Airflow

scheduler_health_check_threshold надо поменять

источник

17:04пожаловаться #19

Max Efremov in Airflow

у меня 30 стоит там

источник

17:04пожаловаться #20