airflow.providers.edge3.plugins.edge_executor_plugin

属性

template_bp

EDGE_EXECUTOR_ACTIVE

类

EdgeWorkerJobs

显示 Edge Worker 作业的简单视图。

EdgeWorkerHosts

显示 Edge Worker 状态的简单视图。

EdgeExecutorPlugin

EdgeExecutor 插件 - 为 Webserver 中的 Edge Worker 提供 API 端点。

函数

modify_maintenance_comment_on_update(...)

模块内容

airflow.providers.edge3.plugins.edge_executor_plugin.modify_maintenance_comment_on_update(maintenance_comment, username)[source]
airflow.providers.edge3.plugins.edge_executor_plugin.template_bp[source]
class airflow.providers.edge3.plugins.edge_executor_plugin.EdgeWorkerJobs[source]

基类: flask_appbuilder.BaseView

显示 Edge Worker 作业的简单视图。

default_view = 'jobs'[source]

此 BaseView 的默认视图，与 url_for（方法名）一起使用

jobs(session=NEW_SESSION)[source]
class airflow.providers.edge3.plugins.edge_executor_plugin.EdgeWorkerHosts[source]

基类: flask_appbuilder.BaseView

显示 Edge Worker 状态的简单视图。

default_view = 'status'[source]

此 BaseView 的默认视图，与 url_for（方法名）一起使用

status(session=NEW_SESSION)[source]
worker_to_maintenance(worker_name)[source]
remove_worker_from_maintenance(worker_name)[source]
remove_worker(worker_name)[source]
change_maintenance_comment(worker_name)[source]
airflow.providers.edge3.plugins.edge_executor_plugin.EDGE_EXECUTOR_ACTIVE = True[source]
class airflow.providers.edge3.plugins.edge_executor_plugin.EdgeExecutorPlugin[source]

基类: airflow.plugins_manager.AirflowPlugin

EdgeExecutor 插件 - 为 Webserver 中的 Edge Worker 提供 API 端点。

name = 'edge_executor'[source]
appbuilder_views[source]

此条目是否有帮助？