from .operators import my_operator
from .sensors import my_sensor
setup(
...
packages=find_namespace_packages(include=["my_plugin", "my_plugin.*"]),
include_package_data=True,
...
)
from airflow.plugins_manager import AirflowPlugin
class MyPlugin(AirflowPlugin):
name = "my_plugin"
operators = [my_operator.MyOperator]
sensors = [my_sensor.MySensor]
...
这样,您就已经注册了您的 operator 或 sensor,并在插件管理中添加了对其的显式依赖关系,因此在后续版本中不会影响 airflow 的升级。