этапе создания таски Airflow иногда выдает неверный хостнейм celery воркера.
Таким образом, таска улетает в никуда, логов нет, маркировка таски случайная - саксес или фэйл. Причем это плавающая проблема, от чего зависит не пойму.
Контейнеры сносил полностью, машину перезагружал, redis вольюмы удалял. После удаления и запуска контейнеров верный хостнейм ожидаемо каждый раз меняется, таски обращённые к нему корректно работают. Но вот проблемный хостнейм всегда один и тот же, как будто он куда-то закэшировался и в случайные (или я закономерности не увидел) моменты времени подменяет собой корректный. Подскажите, где можно отыскать место его хранения и вычистить? Или может как то иначе решить проблему.
Показал бы скриншот из вебморды, но тут запрещено(
community chart?
Не понял вопрос
что значит неверный хостнейм?
Docker network даёт контейнеру с celery хостнейм, например a1b2c3d4. При залезании внутрь контейнера фигурирует этот хостнейм, по нему пингуетс контейнер и так далее. Во вкладке Jobs в вебморде аирфлоу есть столбец hostname - там так же написан этот хостнейм к каждому запуску таски. НО иногда в этом столбце левый хостнейм типа a5b6c7d8. Джобы с этим хостнеймом всегда не имеют лога, не выполняются и помечают себя произвольно саксес или фейл. После docker-compose down верный хостнейм изменяется, потому что новое все создаётся, а вот неверный остаётся тот же самый.
Откуда этот хост? Он не может снифига появиться, кури логи доцкера всех машин
Да вот понятия не имею, он вообще нигде не фигурирует. В логах не грепается, в других контейнерах тоже. Ниоткуда не пингуется. Выглядит так, будто это какое-то закэшированное значение, но где и как не понятно.
А ты пробовал задавать кастомные имена для контейнеров и указывать эти имена как эндпоинты?
Как-то не подумал, хотя очевидное. Спасибо, попробую
Обсуждают сегодня