include collection param

artefactual-labs · Jul 13, 2023 · 725ce4a · 725ce4a
1 parent 83ebca4
commit 725ce4a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/internal/batch/workflow.go b/internal/batch/workflow.go
@@ -70,6 +70,7 @@ func (a *BatchActivity) Execute(ctx context.Context, params BatchWorkflowInput)
 			ProcessingConfig: params.ProcessingConfig,
 			CompletedDir:     params.CompletedDir,
 			RetentionPeriod:  params.RetentionPeriod,
+			RejectDuplicates: params.RejectDuplicates,
 		}
 		_ = a.batchsvc.InitProcessingWorkflow(ctx, &req)
 	}