Airflow - как перезагрузить операторов и плагины - PullRequest
Новая
       8

Airflow - как перезагрузить операторов и плагины

0 голосов
/ 06 июля 2018

Я новичок в Airflow и не могу понять, как перезагрузить оператор / плагин, когда я изменяю его код. Я использую LocalExecutor и внешнюю базу данных (MySql). Я попытался перезапустить веб-сервер и планировщик, но при импорте пакетов все равно появляется та же ошибка: 

    File "/home/ec2-user/airflow/dags/extractor.py", line 2, in <module>
    from airflow.contrib.operators.emr_spark_plugin import EmrSparkOperator
ImportError: No module named emr_spark_plugin

1 Ответ

0 голосов
/ 07 июля 2018

Попробуйте перезапустить веб-сервер и планировщик.

На самом деле нет хорошего встроенного способа сделать это, я рекомендую использовать systemd, как предложено в этом ответе .

...