in services/metadata_service/api/task.py [0:0]
def __init__(self, app):
app.router.add_route(
"GET",
"/flows/{flow_id}/runs/{run_number}/steps/{step_name}/tasks",
self.get_tasks,
)
app.router.add_route(
"GET",
"/flows/{flow_id}/runs/{run_number}/steps/{step_name}/filtered_tasks",
self.get_filtered_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(
"POST",
"/flows/{flow_id}/runs/{run_number}/steps/{step_name}/task",
self.create_task,
)
app.router.add_route("POST",
"/flows/{flow_id}/runs/{run_number}/steps/{step_name}/tasks/{task_id}/heartbeat",
self.tasks_heartbeat)
self._async_table = AsyncPostgresDB.get_instance().task_table_postgres
self._async_run_table = AsyncPostgresDB.get_instance().run_table_postgres
self._async_metadata_table = AsyncPostgresDB.get_instance().metadata_table_postgres
self._db = AsyncPostgresDB.get_instance()