in services/ui_backend_service/api/log.py [0:0]
def __init__(self, app, db, cache=None):
self.db = db
app.router.add_route(
"GET",
"/flows/{flow_id}/runs/{run_number}/steps/{step_name}/tasks/{task_id}/logs/out",
self.get_task_log_stdout,
)
app.router.add_route(
"GET",
"/flows/{flow_id}/runs/{run_number}/steps/{step_name}/tasks/{task_id}/logs/err",
self.get_task_log_stderr,
)
app.router.add_route(
"GET",
"/flows/{flow_id}/runs/{run_number}/steps/{step_name}/tasks/{task_id}/logs/out/download",
self.get_task_log_stdout_file,
)
app.router.add_route(
"GET",
"/flows/{flow_id}/runs/{run_number}/steps/{step_name}/tasks/{task_id}/logs/err/download",
self.get_task_log_stderr_file,
)
self.metadata_table = self.db.metadata_table_postgres
self.task_table = self.db.task_table_postgres
# Cache to hold already fetched logs
self.cache = getattr(cache, "log_cache", None)