We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
We should support timeout per task and allow user to cancel task processing using the CLI.
Cancellation would be useful in two cases:
Optional timeout per task is used in cases such as:
In order to support both cancel and timeout, we need to change the Handler interface.
Handler
type Handler interface { func ProcessTask(ctx context.Context, t *Task) error }
and add Timeout function to create a timeout option when scheduling a task.
Timeout
client.Schedule(task, time.Now().Add(time.Hour), asynq.Timeout(10 * time.Second))
CLI will have a new command to cancel a in-progress task:
asynqmon cancel [task_id]
A cancelled task should be moved to retry state consuming a retry count.
The text was updated successfully, but these errors were encountered:
hibiken
Successfully merging a pull request may close this issue.
We should support timeout per task and allow user to cancel task processing using the CLI.
Cancellation would be useful in two cases:
Optional timeout per task is used in cases such as:
In order to support both cancel and timeout, we need to change the
Handler
interface.and add
Timeout
function to create a timeout option when scheduling a task.CLI will have a new command to cancel a in-progress task:
A cancelled task should be moved to retry state consuming a retry count.
The text was updated successfully, but these errors were encountered: