diff --git a/connectors/src/connectors/slack/temporal/workflows.ts b/connectors/src/connectors/slack/temporal/workflows.ts index 4d1fe6f893eb..1cb12c98c351 100644 --- a/connectors/src/connectors/slack/temporal/workflows.ts +++ b/connectors/src/connectors/slack/temporal/workflows.ts @@ -54,15 +54,11 @@ 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], @@ -70,6 +66,7 @@ export async function workspaceFullSync( 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 index 850069d8ddd0..b5b4b26cfd88 100644 --- 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++; },