Bump scrub workspace parallelism (#5126)

dust-tt · May 18, 2024 · 36d88cd · 36d88cd
1 parent 79406c7
commit 36d88cd
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/front/temporal/scrub_workspace/activities.ts b/front/temporal/scrub_workspace/activities.ts
@@ -98,8 +98,7 @@ async function deleteAllConversations(auth: Authenticator) {
     "Deleting all conversations for workspace."
   );
 
-  // Temporary until we ease the load on the DB.
-  const conversationChunks = chunk(conversations, 1);
+  const conversationChunks = chunk(conversations, 4);
   for (const conversationChunk of conversationChunks) {
     await Promise.all(
       conversationChunk.map(async (c) => {

diff --git a/front/temporal/scrub_workspace/worker.ts b/front/temporal/scrub_workspace/worker.ts
@@ -13,7 +13,7 @@ export async function runScrubWorkspaceQueueWorker() {
   const worker = await Worker.create({
     workflowsPath: require.resolve("./workflows"),
     activities,
-    maxConcurrentActivityTaskExecutions: 1,
+    maxConcurrentActivityTaskExecutions: 2,
     taskQueue: QUEUE_NAME,
     connection,
     namespace,