Skip to content

Commit

Permalink
work
Browse files Browse the repository at this point in the history
  • Loading branch information
mcantelon committed May 30, 2024
1 parent 3bef434 commit ed0d296
Show file tree
Hide file tree
Showing 4 changed files with 0 additions and 167 deletions.
4 changes: 0 additions & 4 deletions cmd/worker/workercmd/cmd.go
Original file line number Diff line number Diff line change
Expand Up @@ -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},
Expand Down
148 changes: 0 additions & 148 deletions internal/activities/combine_premis.go

This file was deleted.

11 changes: 0 additions & 11 deletions internal/workflow/preprocessing.go
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand Down
4 changes: 0 additions & 4 deletions internal/workflow/preprocessing_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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},
Expand Down

0 comments on commit ed0d296

Please sign in to comment.