Обновление кода локального модуля в Apache Airflow - PullRequest
0 голосов
/ 28 августа 2018

У меня есть следующая структура папок в папке Airflow dag.

/opt/airflow/dags
--my_module/
--my_dag.py

Файл Dag (my_dag.py) нуждается в скриптах Python внутри my_module для выполнения задач рабочего процесса.

Вышеуказанные настройки работают отлично, но при обновлении скрипта Python внутри папки «my_module» он не отражается в рабочем процессе.

При изменении файла dag он будет отражать изменения в потоке воздуха. Я также возобновил воздушный поток, но не повезло. Что я тут не так делаю ...

1 Ответ

0 голосов
/ 28 августа 2018

Попробуйте перезапустить и Airflow Webserver, и Планировщик

...