in services/ui_backend_service/api/task.py [0:0]
def __init__(self, app, db, cache=None):
self.db = db
app.router.add_route(
"GET",
"/flows/{flow_id}/runs/{run_number}/tasks",
self.get_run_tasks,
)
app.router.add_route(
"GET",
"/flows/{flow_id}/runs/{run_number}/steps/{step_name}/tasks",
self.get_step_tasks,
)
app.router.add_route(
"GET",
"/flows/{flow_id}/runs/{run_number}/steps/{step_name}/tasks/{task_id}",
self.get_task,
)
app.router.add_route(
"GET",
"/flows/{flow_id}/runs/{run_number}/steps/{step_name}/tasks/{task_id}/attempts",
self.get_task_attempts,
)
self._async_table = self.db.task_table_postgres
self._async_run_table = self.db.run_table_postgres
self.refiner = TaskRefiner(cache=cache.artifact_cache) if cache else None