diff --git a/app/temporal/src/workflows/importer.workflow.ts b/app/temporal/src/workflows/importer.workflow.ts index 2acf954..f6201a4 100644 --- a/app/temporal/src/workflows/importer.workflow.ts +++ b/app/temporal/src/workflows/importer.workflow.ts @@ -198,10 +198,7 @@ export async function importer(params: ImporterWorkflowParams) { const chunkedFileReferences = await acts.applyMappings({ bucket: sourceFile!.bucket, fileReference: sourceFileReference, - dataMapping: configuredMappings!.map((item) => ({ - sourceColumn: item.sourceColumn, - targetColumn: item.targetColumn, - })), + dataMapping: configuredMappings!, }); const mappedSourceDataFileReference = "target.json"; await acts.mergeChunks({