syncProgress nits (#3156)

* slack: progress nits * shorter
dust-tt · Jan 11, 2024 · 96ed9b7 · 96ed9b7
1 parent 2337e1c
commit 96ed9b7
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 10 deletions.
diff --git a/connectors/src/connectors/slack/temporal/workflows.ts b/connectors/src/connectors/slack/temporal/workflows.ts
@@ -54,22 +54,19 @@ export async function workspaceFullSync(
     for (const channelId of input.channelIds) {
       promises.push(
         childWorkflowQueue.add(async () => {
-          const percentSync = Math.round(
-            (i / Math.max(promises.length, input.channelIds.length)) * 100
-          );
           await reportInitialSyncProgressActivity(
             connectorId,
-            `${percentSync}%`
+            `${i - 1}/${input.channelIds.length} channels`
           );
-          i++;
-          return executeChild(syncOneChannel, {
+          await executeChild(syncOneChannel, {
             workflowId: syncOneChanneWorkflowlId(connectorId, channelId),
             searchAttributes: {
               connectorId: [connectorId],
             },
             args: [connectorId, channelId, false, fromTs],
             memo: workflowInfo().memo,
           });
+          i++;
         })
       );
     }

diff --git a/connectors/src/connectors/webcrawler/temporal/activities.ts b/connectors/src/connectors/webcrawler/temporal/activities.ts
@@ -122,10 +122,7 @@ export async function crawlWebsiteByConnectorId(connectorId: ModelId) {
           },
         });
 
-        await reportInitialSyncProgress(
-          connector.id,
-          `Crawled ${pageCount} pages.`
-        );
+        await reportInitialSyncProgress(connector.id, `${pageCount} pages`);
 
         pageCount++;
       },