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

属性¶

`fetch`(worker_name, body, session)	获取一个任务以便在边缘工作节点上执行。
`state`(dag_id, task_id, run_id, try_number, map_index, ...)	更新在边缘工作节点上运行的任务的状态。

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

获取一个任务以便在边缘工作节点上执行。

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

更新在边缘工作节点上运行的任务的状态。