airflow.providers.edge3.worker_api.routes.logs¶

属性¶

`logfile_path`(dag_id, task_id, run_id, try_number, ...)	详细说明任务执行时预期的路径和文件名。
`push_logs`(dag_id, task_id, run_id, try_number, ...)	将增量日志块从 Edge Worker 推送到中央站点。

airflow.providers.edge3.worker_api.routes.logs.logfile_path(dag_id, task_id, run_id, try_number, map_index)[源]¶

详细说明任务执行时预期的路径和文件名。

airflow.providers.edge3.worker_api.routes.logs.push_logs(dag_id, task_id, run_id, try_number, map_index, body, session)[源]¶

将增量日志块从 Edge Worker 推送到中央站点。