work

artefactual-sdps · May 14, 2024 · cae59a6 · cae59a6
1 parent 3cde1d2
commit cae59a6
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/cmd/worker/workercmd/cmd.go b/cmd/worker/workercmd/cmd.go
@@ -70,6 +70,10 @@ func (m *Main) Run(ctx context.Context) error {
 		activities.NewMetadataValidationActivity().Execute,
 		temporalsdk_activity.RegisterOptions{Name: activities.MetadataValidationName},
 	)
+	w.RegisterActivityWithOptions(
+		activities.CombinePremisActivity().Execute,
+		temporalsdk_activity.RegisterOptions{Name: activities.CombinePremisName},
+	)
 	w.RegisterActivityWithOptions(
 		activities.NewSipCreationActivity().Execute,
 		temporalsdk_activity.RegisterOptions{Name: activities.SipCreationName},

diff --git a/internal/workflow/preprocessing.go b/internal/workflow/preprocessing.go
@@ -102,6 +102,16 @@ func (w *PreprocessingWorkflow) Execute(
 		return nil, e
 	}
 
+	// Combine PREMIS files into one
+	var combinePremis activities.CombinePremisResult
+	e = temporalsdk_workflow.ExecuteActivity(withLocalActOpts(ctx), activities.CombinePremisName, &activities.CombinePremisParams{
+		SipPath: localPath,
+	}).
+		Get(ctx, &combinePremis)
+	if e != nil {
+		return nil, e
+	}
+
 	// Repackage SFA SIP into a Bag.
 	var sipCreation activities.SipCreationResult
 	e = temporalsdk_workflow.ExecuteActivity(withLocalActOpts(ctx), activities.SipCreationName, &activities.SipCreationParams{