improve: query perf by adding batchSize and highWaterMark to QueryStream

Author: skwowet

services/libs/data-access-layer/src/activities/update.ts

@@ -19,7 +19,10 @@ export async function streamActivities(
   params?: Record<string, unknown>,
 ): Promise<{ processed: number; duration: number }> {
   const whereClause = formatQuery(where, params)
-  const qs = new QueryStream(`SELECT * FROM activities WHERE ${whereClause}`)
+  const qs = new QueryStream(`SELECT * FROM activities WHERE ${whereClause}`, [], {
+    batchSize: 1000,
+    highWaterMark: 250,
+  })
 
   const t = timer(logger, `query activities with ${whereClause}`)