forgot

pcrespov · pcrespov · commit cacfba61cc56 · 2024-11-11T18:34:14.000+01:00
diff --git a/services/web/server/src/simcore_service_webserver/workspaces/_groups_db.py b/services/web/server/src/simcore_service_webserver/workspaces/_groups_db.py
@@ -92,9 +92,8 @@ async def list_workspace_groups(
     )
 
     async with pass_or_acquire_connection(get_asyncpg_engine(app), connection) as conn:
-        result = await conn.execute(stmt)
-        rows = result.fetchall() or []
-        return [WorkspaceGroupGetDB.from_orm(row) for row in rows]
+        result = await conn.stream(stmt)
+        return [WorkspaceGroupGetDB.from_orm(row) async for row in result]
 
 
 async def get_workspace_group(

Original file line number	Diff line number	Diff line change
`@@ -92,9 +92,8 @@ async def list_workspace_groups(`
`92`	`92`	`)`
`93`	`93`
`94`	`94`	`async with pass_or_acquire_connection(get_asyncpg_engine(app), connection) as conn:`
`95`		`- result = await conn.execute(stmt)`
`96`		`- rows = result.fetchall() or []`
`97`		`- return [WorkspaceGroupGetDB.from_orm(row) for row in rows]`
	`95`	`+ result = await conn.stream(stmt)`
	`96`	`+ return [WorkspaceGroupGetDB.from_orm(row) async for row in result]`
`98`	`97`
`99`	`98`
`100`	`99`	`async def get_workspace_group(`