M
Size: a a a
2020 June 29
SG
в смысле не получится?
Человек хочет, чтобы наличие Переменных проверялось в момент, когда он в даге жмёт "ВКЛ". А это невозможно никак, кроме как в таске проверить
SG
Нет
DM
@roveo Я использую кубер оператор, там при инициализации в конструкторе требуется как миниимум: namespace, image, name
SG
Всё, вопрос снят
SG
Я тут ничем не могу помочь
DM
я сделал кастомный оператор на основе куберовского оператора, следовательно мой оператор в конструкторе принимает эти переменные и кладет в конструктор куберовского
M
я сделал кастомный оператор на основе куберовского оператора, следовательно мой оператор в конструкторе принимает эти переменные и кладет в конструктор куберовского
передавайте аргументом в конструкторе имена переменных, а чтение делайте уже на уровне метода execute
DM
сорян я не эксперт питона, я уверен что скорее всего я как то криво сделал. Спасибо всем за помощь, щас попробую разобраться с примером выше
DM
передавайте аргументом в конструкторе имена переменных, а чтение делайте уже на уровне метода execute
Понял, спасибо
SG
ну я про это и говорю
Извиняюсь, был не прав
N
Добрый вечер! Есть кластер, состоящий из шедулера и двух воркеров. Подскажите, пожалуйста, с чем может быть связано то, что даги выполняются в основном на втором воркере? В логах никаких ошибок не нашёл. Должна ли нагрузка балансировать поровну или это происходит в случайном порядке, и такая картина является нормальной?
SG
Добрый вечер! Есть кластер, состоящий из шедулера и двух воркеров. Подскажите, пожалуйста, с чем может быть связано то, что даги выполняются в основном на втором воркере? В логах никаких ошибок не нашёл. Должна ли нагрузка балансировать поровну или это происходит в случайном порядке, и такая картина является нормальной?
У вас же загружено не целиком?
SG
Да, не целиком. Всё-таки, есть какая-то проблема: в Flower ui воркер периодически уходит в offline, но логи сервиса ошибок не содержат
Тогда проблема именно в этом, а не в неравномерной нагрузке
SG
А у вас есть хэлсчеки?
SG
Вы имеете в виду страничку /health?
Не, я имею в виду внешний механизм, который проверяет работоспособность воркера