airflow.providers.edge.plugins.edge_executor_plugin¶

Attributes¶

`template_bp`
`EDGE_EXECUTOR_ACTIVE`

`EdgeWorkerJobs`	Simple view to show Edge Worker jobs.
`EdgeWorkerHosts`	Simple view to show Edge Worker status.
`EdgeExecutorPlugin`	EdgeExecutor Plugin - provides API endpoints for Edge Workers in Webserver.

class airflow.providers.edge.plugins.edge_executor_plugin.EdgeWorkerJobs[source]¶

Bases: flask_appbuilder.BaseView

Simple view to show Edge Worker jobs.

default_view = 'jobs'[source]¶: the default view for this BaseView, to be used with url_for (method name)

jobs(session=NEW_SESSION)[source]¶

class airflow.providers.edge.plugins.edge_executor_plugin.EdgeWorkerHosts[source]¶

Bases: flask_appbuilder.BaseView

Simple view to show Edge Worker status.

default_view = 'status'[source]¶: the default view for this BaseView, to be used with url_for (method name)

status(session=NEW_SESSION)[source]¶

worker_to_maintenance(worker_name)[source]¶

remove_worker_from_maintenance(worker_name)[source]¶

remove_worker(worker_name)[source]¶

airflow.providers.edge.plugins.edge_executor_plugin.EDGE_EXECUTOR_ACTIVE = True[source]¶

class airflow.providers.edge.plugins.edge_executor_plugin.EdgeExecutorPlugin[source]¶

Bases: airflow.plugins_manager.AirflowPlugin

EdgeExecutor Plugin - provides API endpoints for Edge Workers in Webserver.