airflow.providers.edge.worker_api.routes.logs

Attributes

logs_router

Functions

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.

Module Contents

airflow.providers.edge.worker_api.routes.logs.logs_router[source]
airflow.providers.edge.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.edge.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.

Was this entry helpful?