airflow.providers.edge3.worker_api.routes.jobs¶

Attributes¶

`fetch`(worker_name, body, session)	Fetch a job to execute on the edge worker.
`state`(dag_id, task_id, run_id, try_number, map_index, ...)	Update the state of a job running on the edge worker.

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

Fetch a job to execute on the edge worker.

airflow.providers.edge3.worker_api.routes.jobs.state(dag_id, task_id, run_id, try_number, map_index, state, session)[source]¶

Update the state of a job running on the edge worker.