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

Attributes¶

`logfile_path`(dag_id, task_id, run_id, try_number, ...)	Elaborate the path and filename to expect from task execution.
`push_logs`(dag_id, task_id, run_id, try_number, ...)	Push an incremental log chunk from Edge Worker to central site.

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

Elaborate the path and filename to expect from task execution.

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

Push an incremental log chunk from Edge Worker to central site.