work

cmd/worker/workercmd/cmd.go

@@ -76,10 +76,6 @@ func (m *Main) Run(ctx context.Context) error {
 		activities.NewValidateMetadata().Execute,
 		temporalsdk_activity.RegisterOptions{Name: activities.ValidateMetadataName},
 	)
-	w.RegisterActivityWithOptions(
-		activities.NewCombinePREMIS().Execute,
-		temporalsdk_activity.RegisterOptions{Name: activities.CombinePREMISName},
-	)
 	w.RegisterActivityWithOptions(
 		activities.NewTransformSIP().Execute,
 		temporalsdk_activity.RegisterOptions{Name: activities.TransformSIPName},

go.mod

@@ -4,7 +4,6 @@ go 1.22.3
 
 require (
 	github.com/artefactual-sdps/temporal-activities v0.0.0-20240528131443-0d1f5defd565
-	github.com/beevik/etree v1.4.0
 	github.com/go-logr/logr v1.4.1
 	github.com/otiai10/copy v1.14.0
 	github.com/richardlehane/siegfried v1.11.0

go.sum

@@ -2,8 +2,6 @@ cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMT
 github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
 github.com/artefactual-sdps/temporal-activities v0.0.0-20240528131443-0d1f5defd565 h1:BlAvtmnDfP/J2ZwYDElMkF6caNQWxOGXlXiCC59tj4A=
 github.com/artefactual-sdps/temporal-activities v0.0.0-20240528131443-0d1f5defd565/go.mod h1:C6z/8k6xFm9wrF4GSMKs13v941MtdrOzH2fn8hQEHtA=
-github.com/beevik/etree v1.4.0 h1:oz1UedHRepuY3p4N5OjE0nK1WLCqtzHf25bxplKOHLs=
-github.com/beevik/etree v1.4.0/go.mod h1:cyWiXwGoasx60gHvtnEh5x8+uIjUVnjWqBvEnhnqKDA=
 github.com/benbjohnson/clock v1.1.0/go.mod h1:J11/hYXuz8f4ySSvYwY0FKfm+ezbsZBKZxNJlLklBHA=
 github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU=
 github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=

internal/workflow/preprocessing.go

@@ -106,17 +106,6 @@ 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{Path: localPath},
-	).Get(ctx, &combinePREMIS)
-	if e != nil {
-		return nil, e
-	}
-
 	// Remove PREMIS files.
 	var removeFiles removefiles.ActivityResult
 	e = temporalsdk_workflow.ExecuteActivity(

internal/workflow/preprocessing_test.go

@@ -57,10 +57,6 @@ func (s *PreprocessingTestSuite) SetupTest(cfg config.Configuration) {
 		activities.NewTransformSIP().Execute,
 		temporalsdk_activity.RegisterOptions{Name: activities.TransformSIPName},
 	)
-	s.env.RegisterActivityWithOptions(
-		activities.NewCombinePREMIS().Execute,
-		temporalsdk_activity.RegisterOptions{Name: activities.CombinePREMISName},
-	)
 	s.env.RegisterActivityWithOptions(
 		removefiles.NewActivity().Execute,
 		temporalsdk_activity.RegisterOptions{Name: removefiles.ActivityName},
@@ -131,13 +127,6 @@ func (s *PreprocessingTestSuite) TestPreprocessingWorkflowSuccess() {
 	).Return(
 		&activities.TransformSIPResult{}, nil,
 	)
-	s.env.OnActivity(
-		activities.CombinePREMISName,
-		sessionCtx,
-		&activities.CombinePREMISParams{Path: sipPath},
-	).Return(
-		&activities.CombinePREMISResult{}, nil,
-	)
 	s.env.OnActivity(
 		removefiles.ActivityName,
 		sessionCtx,