[QUESTION] Way to determine a task is a retry

[hibiken]

[QUESTION] Way to determine a task is a retry

[hibiken]

Proposal

Here's my initial proposal. Please let me know if you have any thoughts or feedback 😃

Export functions to extract task metadata from context:

GetTaskID(ctx context.Context) (id string, ok bool)

GetRetryCount(ctx context.Context) (n int, ok bool)

GetMaxRetry(ctx context.Context) (n int, ok bool)

Example

func (h *MyHandler) ProcessTask(ctx context.Context, t *asynq.Task) error {
    retried, ok := asynq.GetRetryCount(ctx)
    if ok {
        log.Printf("this task has been retried for %d times", retried)
    }
    
    // ... rest of the handler logic
}

[hibiken]

Great question and thanks for opening this issue.

Current APIs don't offer an ability to determine whether a Task passed to your Handler is a retry task.

I think it makes total sense to put task metadata such as RetryCount in the context Value.
I'll do a little bit of research and update this thread with a proposal 👍

[jimmy-ho]

@hibiken looks good to me, thanks for your time in looking into this.