diff --git a/front/scrub_workspace/temporal/activities.ts b/front/scrub_workspace/temporal/activities.ts index 56f8d85a66d2c..41253cc07ade6 100644 --- a/front/scrub_workspace/temporal/activities.ts +++ b/front/scrub_workspace/temporal/activities.ts @@ -79,11 +79,12 @@ export async function stopAllConnectors({ }) { const auth = await Authenticator.internalAdminForWorkspace(workspaceId); const dataSources = await getDataSources(auth); - const connectedDataSources = dataSources.filter((ds) => !!ds.connectorId); const connectorsApi = new ConnectorsAPI(logger); - for (const ds of connectedDataSources) { - void connectorsApi; - void ds; + for (const ds of dataSources) { + if (!ds.connectorId) { + continue; + } + await connectorsApi.stopConnector(ds.connectorId); } }