diff --git a/internal/workflow/policies.go b/internal/workflow/policies.go index 2ad914c3..15c51f6d 100644 --- a/internal/workflow/policies.go +++ b/internal/workflow/policies.go @@ -62,8 +62,8 @@ func withActivityOptsForRequest(ctx temporalsdk_workflow.Context) temporalsdk_wo } // withActivityOptsForLocalAction returns a workflow context with activity -// options suited for local activities like disk operations that should not -// require a retry policy attached. +// options suited for local actions like disk operations that should not require +// a retry policy attached. func withActivityOptsForLocalAction(ctx temporalsdk_workflow.Context) temporalsdk_workflow.Context { return temporalsdk_workflow.WithActivityOptions(ctx, temporalsdk_workflow.ActivityOptions{ StartToCloseTimeout: time.Hour, diff --git a/internal/workflow/processing.go b/internal/workflow/processing.go index b9b39b59..7b2558ed 100644 --- a/internal/workflow/processing.go +++ b/internal/workflow/processing.go @@ -481,7 +481,7 @@ func (w *ProcessingWorkflow) SessionHandler(sessCtx temporalsdk_workflow.Context // Delete local temporary files. defer func() { if tinfo.Bundle.FullPathBeforeStrip != "" { - activityOpts := withActivityOptsForRequest(sessCtx) + activityOpts := withActivityOptsForLocalAction(sessCtx) _ = temporalsdk_workflow.ExecuteActivity(activityOpts, activities.CleanUpActivityName, &activities.CleanUpActivityParams{ FullPath: tinfo.Bundle.FullPathBeforeStrip, }).Get(activityOpts, nil)