From 6bb481850971dbcbfbb203e09ef18191892826b1 Mon Sep 17 00:00:00 2001 From: Ken Hibino Date: Sat, 6 Nov 2021 06:38:36 -0700 Subject: [PATCH] Update readme --- README.md | 18 +++--------------- 1 file changed, 3 insertions(+), 15 deletions(-) diff --git a/README.md b/README.md index 7c62d29..15237b2 100644 --- a/README.md +++ b/README.md @@ -103,7 +103,8 @@ func NewImageResizeTask(src string) (*asynq.Task, error) { if err != nil { return nil, err } - return asynq.NewTask(TypeImageResize, payload), nil + // task options can be passed to NewTask, which can be overridden at enqueue time. + return asynq.NewTask(TypeImageResize, payload, asynq.MaxRetry(5), asynq.Timeout(20 * time.Minute)), nil } //--------------------------------------------------------------- @@ -196,24 +197,11 @@ func main() { // Options include MaxRetry, Queue, Timeout, Deadline, Unique etc. // ---------------------------------------------------------------------------- - client.SetDefaultOptions(tasks.TypeImageResize, asynq.MaxRetry(10), asynq.Timeout(3*time.Minute)) - task, err = tasks.NewImageResizeTask("https://example.com/myassets/image.jpg") if err != nil { log.Fatalf("could not create task: %v", err) } - info, err = client.Enqueue(task) - if err != nil { - log.Fatalf("could not enqueue task: %v", err) - } - log.Printf("enqueued task: id=%s queue=%s", info.ID, info.Queue) - - // --------------------------------------------------------------------------- - // Example 4: Pass options to tune task processing behavior at enqueue time. - // Options passed at enqueue time override default ones. - // --------------------------------------------------------------------------- - - info, err = client.Enqueue(task, asynq.Queue("critical"), asynq.Timeout(30*time.Second)) + info, err = client.Enqueue(task, asynq.MaxRetry(10), asynq.Timeout(3 * time.Minute)) if err != nil { log.Fatalf("could not enqueue task: %v", err) }