airflow.providers.edge3.worker_api.routes.ui¶

Attributes¶

`worker`(session)	Return Edge Workers.
`jobs`(session)	Return Edge Jobs.
`request_worker_maintenance`(worker_name, ...)	Put a worker into maintenance mode.
`update_worker_maintenance`(worker_name, ...)	Update maintenance comments for a worker.
`exit_worker_maintenance`(worker_name, session)	Exit a worker from maintenance mode.
`request_worker_shutdown`(worker_name, session)	Request shutdown of a worker.
`delete_worker`(worker_name, session)	Delete a worker record from the system.
`add_worker_queue`(worker_name, queue_name, session)	Add a queue to a worker.
`remove_worker_queue`(worker_name, queue_name, session)	Remove a queue from a worker.

airflow.providers.edge3.worker_api.routes.ui.worker(session)[source]¶

Return Edge Workers.

airflow.providers.edge3.worker_api.routes.ui.jobs(session)[source]¶

Return Edge Jobs.

airflow.providers.edge3.worker_api.routes.ui.request_worker_maintenance(worker_name, maintenance_request, session, user)[source]¶

Put a worker into maintenance mode.

airflow.providers.edge3.worker_api.routes.ui.update_worker_maintenance(worker_name, maintenance_request, session, user)[source]¶

Update maintenance comments for a worker.

airflow.providers.edge3.worker_api.routes.ui.exit_worker_maintenance(worker_name, session)[source]¶

Exit a worker from maintenance mode.

airflow.providers.edge3.worker_api.routes.ui.request_worker_shutdown(worker_name, session)[source]¶

Request shutdown of a worker.

airflow.providers.edge3.worker_api.routes.ui.delete_worker(worker_name, session)[source]¶

Delete a worker record from the system.

airflow.providers.edge3.worker_api.routes.ui.add_worker_queue(worker_name, queue_name, session)[source]¶

Add a queue to a worker.

airflow.providers.edge3.worker_api.routes.ui.remove_worker_queue(worker_name, queue_name, session)[source]¶

Remove a queue from a worker.