diff --git a/internal/workflow/poll_ingest_activity.go b/internal/workflow/poll_ingest_activity.go index 4fefa1bd..7fb292cb 100644 --- a/internal/workflow/poll_ingest_activity.go +++ b/internal/workflow/poll_ingest_activity.go @@ -33,7 +33,7 @@ func (a *PollIngestActivity) Execute(ctx context.Context, tinfo *TransferInfo) ( err = pipeline.IngestStatus(ctx, amc, tinfo.SIPID) if errors.Is(err, pipeline.ErrStatusNonRetryable) { - return backoff.Permanent(err) + return backoff.Permanent(nonRetryableError(err)) } return err diff --git a/internal/workflow/poll_transfer_activity.go b/internal/workflow/poll_transfer_activity.go index 24fe7482..e1bb23a5 100644 --- a/internal/workflow/poll_transfer_activity.go +++ b/internal/workflow/poll_transfer_activity.go @@ -34,7 +34,7 @@ func (a *PollTransferActivity) Execute(ctx context.Context, tinfo *TransferInfo) sipID, err = pipeline.TransferStatus(ctx, amc, tinfo.TransferID) if errors.Is(err, pipeline.ErrStatusNonRetryable) { - return backoff.Permanent(err) + return backoff.Permanent(nonRetryableError(err)) } return err