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

Attributes¶

`log`
`jobs_router`

Functions¶

`parse_command`(command, dag_id, task_id, run_id, ...)
`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.

Module Contents¶

airflow.providers.edge3.worker_api.routes.jobs.log[source]¶

airflow.providers.edge3.worker_api.routes.jobs.jobs_router[source]¶

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

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, task_instance_id=None)[source]¶

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