From 6713f0f3ae1c7972b850f9b2d7395c6aa363396e Mon Sep 17 00:00:00 2001 From: Mohammed Sohail Date: Tue, 25 Oct 2022 14:58:16 +0000 Subject: [PATCH] perf(tasker): update retry strategy * closes #20 --- internal/tasker/server/server.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/internal/tasker/server/server.go b/internal/tasker/server/server.go index 575fbcb..5355dd1 100644 --- a/internal/tasker/server/server.go +++ b/internal/tasker/server/server.go @@ -1,6 +1,8 @@ package server import ( + "time" + "github.com/grassrootseconomics/cic-custodial/internal/actions" tasker_client "github.com/grassrootseconomics/cic-custodial/internal/tasker/client" "github.com/hibiken/asynq" @@ -38,6 +40,13 @@ func NewTaskerServer(o Opts) *TaskerServer { asynq.Config{ Concurrency: o.Concurrency, Logger: asynqCompatibleLogger(o.Logger), + RetryDelayFunc: func(n int, e error, t *asynq.Task) time.Duration { + if n < 6 { + return 1 * time.Second + } else { + return asynq.DefaultRetryDelayFunc(n, e, t) + } + }, }, )