airflow.providers.edge3.worker_api.routes.worker¶

Attributes¶

`DualStatsManager`
`worker_router`

Functions¶

`redefine_state`(worker_state, body_state)	Redefine the state of the worker based on maintenance or shutdown request.
`redefine_maintenance_comments`(...)	Add new maintenance comments or overwrite the old ones if it is too long.
`register`(worker_name, body, session)	Register a new worker to the backend.
`set_state`(worker_name, body, session)	Set state of worker and returns the current assigned queues.
`update_queues`(worker_name, body, session)

Module Contents¶

airflow.providers.edge3.worker_api.routes.worker.DualStatsManager = None[source]¶

airflow.providers.edge3.worker_api.routes.worker.worker_router[source]¶

airflow.providers.edge3.worker_api.routes.worker.redefine_state(worker_state, body_state)[source]¶

Redefine the state of the worker based on maintenance or shutdown request.

airflow.providers.edge3.worker_api.routes.worker.redefine_maintenance_comments(worker_maintenance_comment, body_maintenance_comments)[source]¶

Add new maintenance comments or overwrite the old ones if it is too long.

airflow.providers.edge3.worker_api.routes.worker.register(worker_name, body, session)[source]¶

Register a new worker to the backend.

airflow.providers.edge3.worker_api.routes.worker.set_state(worker_name, body, session)[source]¶

Set state of worker and returns the current assigned queues.

airflow.providers.edge3.worker_api.routes.worker.update_queues(worker_name, body, session)[source]¶