diff --git a/webapps/console/lib/server/fast-store.ts b/webapps/console/lib/server/fast-store.ts index 4ea3b0ac2..ec5befe5c 100644 --- a/webapps/console/lib/server/fast-store.ts +++ b/webapps/console/lib/server/fast-store.ts @@ -282,6 +282,7 @@ async function saveConnectionsToRedis(db: DatabaseConnection) { // const streamConfig = flatten(obj); // addStreamByDomain(streamConfig, [], row.backupEnabled); // }); + await db.pgHelper().streamQuery(query, async row => { const workspaceId = row.workspaceId; const linkId = row.id;