diff --git a/base_folder/src/functions/extraction/index.ts b/base_folder/src/functions/extraction/index.ts index b62c97c..120f9d2 100644 --- a/base_folder/src/functions/extraction/index.ts +++ b/base_folder/src/functions/extraction/index.ts @@ -6,6 +6,7 @@ export interface ExtractorState {} export const initialState: ExtractorState = {}; + function getWorkerPerExtractionPhase(event: FunctionInput) { let path; switch (event.payload.event_type) { diff --git a/base_folder/src/functions/extraction/workers/attachments-extraction.ts b/base_folder/src/functions/extraction/workers/attachments-extraction.ts index 5d1945e..ee7ac13 100644 --- a/base_folder/src/functions/extraction/workers/attachments-extraction.ts +++ b/base_folder/src/functions/extraction/workers/attachments-extraction.ts @@ -1,7 +1,6 @@ import { ExtractorEventType, processTask } from '@devrev/ts-adaas'; -import { ExtractorState } from "../index"; -processTask({ +processTask({ task: async ({ adapter }) => {}, onTimeout: async ({ adapter }) => { await adapter.emit(ExtractorEventType.ExtractionAttachmentsProgress); diff --git a/base_folder/src/functions/extraction/workers/external-sync-units-extraction.ts b/base_folder/src/functions/extraction/workers/external-sync-units-extraction.ts index f665e03..77ac232 100644 --- a/base_folder/src/functions/extraction/workers/external-sync-units-extraction.ts +++ b/base_folder/src/functions/extraction/workers/external-sync-units-extraction.ts @@ -1,7 +1,6 @@ import { ExtractorEventType, processTask } from "@devrev/ts-adaas"; -import { ExtractorState } from "../index"; -processTask({ +processTask({ task: async ({ adapter }) => {}, onTimeout: async ({ adapter }) => { await adapter.emit(ExtractorEventType.ExtractionExternalSyncUnitsError, { diff --git a/base_folder/src/functions/extraction/workers/metadata-extraction.ts b/base_folder/src/functions/extraction/workers/metadata-extraction.ts index 9bb0103..747d69f 100644 --- a/base_folder/src/functions/extraction/workers/metadata-extraction.ts +++ b/base_folder/src/functions/extraction/workers/metadata-extraction.ts @@ -1,7 +1,6 @@ import { processTask, ExtractorEventType } from '@devrev/ts-adaas'; -import { ExtractorState } from '../index'; -processTask({ +processTask({ task: async ({ adapter }) => {}, onTimeout: async ({ adapter }) => { await adapter.emit(ExtractorEventType.ExtractionMetadataError, {