Airflow - 如何重新加载操作符和插件

Question

我是 Airflow 的新手，当我更改其代码时，我无法理解如何重新加载运算符(operator)/插件。
我正在使用 LocalExecutor 和外部数据库 (MySql)。
我尝试重新启动网络服务器和调度程序，但在导入 dag 时仍然出现相同的错误:

    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

Answer 1

尝试重新启动 Web 服务器和调度程序。

实际上没有好的内置方法可以做到这一点，我建议按照 this answer 中的建议使用 systemd。 .