diff --git a/internal/workflow/processing.go b/internal/workflow/processing.go index 6f2cb53b..5504d52e 100644 --- a/internal/workflow/processing.go +++ b/internal/workflow/processing.go @@ -967,6 +967,7 @@ func (w *ProcessingWorkflow) transferAM( &am.StartTransferActivityParams{ Name: tinfo.req.Key, RelativePath: uploadResult.RemoteRelativePath, + ZipPIP: w.cfg.AM.ZipPIP, }, ).Get(activityOpts, &transferResult) if err != nil { diff --git a/internal/workflow/processing_test.go b/internal/workflow/processing_test.go index 19e02f3f..24d137d6 100644 --- a/internal/workflow/processing_test.go +++ b/internal/workflow/processing_test.go @@ -754,7 +754,7 @@ func (s *ProcessingWorkflowTestSuite) TestAMWorkflow() { ) s.env.OnActivity(am.StartTransferActivityName, sessionCtx, - &am.StartTransferActivityParams{Name: key, RelativePath: "transfer.zip"}, + &am.StartTransferActivityParams{Name: key, RelativePath: "transfer.zip", ZipPIP: true}, ).Return( &am.StartTransferActivityResult{TransferID: transferID.String()}, nil, )