diff --git a/internal/context/context.go b/internal/context/context.go index 9b233ce..47257d6 100644 --- a/internal/context/context.go +++ b/internal/context/context.go @@ -30,7 +30,7 @@ const metadataCtxKey ctxKey = 0 // New returns a context and cancel function for a given task message. func New(msg *base.TaskMessage, deadline time.Time) (context.Context, context.CancelFunc) { metadata := taskMetadata{ - id: msg.ID.String(), + id: msg.ID, maxRetry: msg.Retry, retryCount: msg.Retried, qname: msg.Queue,