in services/metadata_service/api/metadata.py [0:0]
def __init__(self, app):
app.router.add_route(
"GET",
"/flows/{flow_id}/runs/{run_number}/steps/{step_name}/"
"tasks/{task_id}/metadata",
self.get_metadata,
)
app.router.add_route(
"GET",
"/flows/{flow_id}/runs/{run_number}/metadata",
self.get_metadata_by_run,
)
app.router.add_route(
"POST",
"/flows/{flow_id}/runs/{run_number}/steps/{step_name}/"
"tasks/{task_id}/metadata",
self.create_metadata,
)
self._db = AsyncPostgresDB.get_instance()
self._async_table = AsyncPostgresDB.get_instance().metadata_table_postgres