Процесс предварительной проверки потоков Азкабана

Я хотел бы проверить свои потоки Azkaban, прежде чем загружать их на сервер, так просто. У нас есть плагин или что-то для этого? Если нет, то какие классы в Azkaban github выполняют эту проверку? Я мог бы просто адаптировать их и использовать для проверки.

Источник

1 ответ

Решение

Я рекомендую использовать Azkaban "CLI", который вы можете найти здесь: https://github.com/mtth/azkaban

Вы отправляете свой проект из терминала и получаете отзыв так:

$ azkaban build -c --project my_project
  > Validator Directory Flow reports errors:<ul><li>my_flow_1 cannot 
    find dependency my_other_flow</li></ul>

$ azkaban build -c --project my_project
  > Project my_project successfully built and uploaded (id: 20, size: 28.2kB, upload: 2).
    Details at https://192.168.0.1:8443/manager?project=my_project

У меня есть конкретный пример job.py формат для CLI по адресу: https://github.com/joeharris76/azkaban_examples

Источник
Другие вопросы по тегам