МС
Поправил hosts заработало
Size: a a a
2018 June 06
SS
В логах нашёл Warning (!!! Не Error !!!) о том что хостнеймы не совпадают.
это ключевая зацепка. спасибо за объяснение
2018 June 08
KS
В логах нашёл Warning (!!! Не Error !!!) о том что хостнеймы не совпадают.
вот у меня точно такая же проблема, что-то убивает таски с "Task received SIGTERM signal", но такого ворнинга нет
KS
какие логи нужно проверить? самой задачи? или мб шедулера?
МС
скедулера
KS
вижу в доке, что шедулер убивает таски, если нет heartbeat. как это работает? это случайно не появление записей в логе?
KS
"Zombie tasks are characterized by the absence of an heartbeat (emitted by the job periodically)"
I
вижу в доке, что шедулер убивает таски, если нет heartbeat. как это работает? это случайно не появление записей в логе?
В базу метаданных в таблицу job пишется апдейт от таски
МС
А никто не сталкивался с тем что таски не завершаются?
МС
Так и висят running
МС
LocalExecutor если что
WC
Так и висят running
Так а разве по тайм ауту не отваливаются?
МС
Неа
KS
вижу в доке, что шедулер убивает таски, если нет heartbeat. как это работает? это случайно не появление записей в логе?
похоже что мои таски убивает celery из за muptiprocessing в них. если кто сталкивался с таким, напишите плз как решали
2018 June 10
МС
На PyCon Russia 2018 будет доклад посвящённый Airflow :)
http://pycon.ru/2018/program/content/Alejandro/
http://pycon.ru/2018/program/content/Alejandro/
МС
Кто-то поедет?
МС
Если да то пишите. Я там буду :)
2018 June 16
KS
регулярно вижу сообщения
dependency 'Task Instance Not Already Running' FAILED: Task is already running, it started on 2018-06-15 16:32:10.011906.
dependency 'Task Instance State' FAILED: Task is in the 'running' state which is not a valid state for execution. The task must be cleared in order to be run.
при этом на celery таск продолжает работать, но в интерфейсе лог отвалился
кто-нибудь сталкивался?
dependency 'Task Instance Not Already Running' FAILED: Task is already running, it started on 2018-06-15 16:32:10.011906.
dependency 'Task Instance State' FAILED: Task is in the 'running' state which is not a valid state for execution. The task must be cleared in order to be run.
при этом на celery таск продолжает работать, но в интерфейсе лог отвалился
кто-нибудь сталкивался?
KS
мое первое предположение, что это из-за visibility_timeout и 'task_acks_late': True,
2018 June 17
I
регулярно вижу сообщения
dependency 'Task Instance Not Already Running' FAILED: Task is already running, it started on 2018-06-15 16:32:10.011906.
dependency 'Task Instance State' FAILED: Task is in the 'running' state which is not a valid state for execution. The task must be cleared in order to be run.
при этом на celery таск продолжает работать, но в интерфейсе лог отвалился
кто-нибудь сталкивался?
dependency 'Task Instance Not Already Running' FAILED: Task is already running, it started on 2018-06-15 16:32:10.011906.
dependency 'Task Instance State' FAILED: Task is in the 'running' state which is not a valid state for execution. The task must be cleared in order to be run.
при этом на celery таск продолжает работать, но в интерфейсе лог отвалился
кто-нибудь сталкивался?
Всегда воспринимал это сообщение как то, что скедулер отказывается запускать таску, так как она уже ранится.