From 1392c03ab07eeb99613f2abb85a3c76c770baa11 Mon Sep 17 00:00:00 2001
From: Mohammed Sohail <sohailsameja@gmail.com>
Date: Tue, 25 Oct 2022 15:06:37 +0000
Subject: [PATCH] fix(tasker): lock obtain as a non error in tasker

* closes #19
---
 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 5355dd1..6a3dbee 100644
--- a/internal/tasker/server/server.go
+++ b/internal/tasker/server/server.go
@@ -3,6 +3,7 @@ package server
 import (
 	"time"
 
+	"github.com/bsm/redislock"
 	"github.com/grassrootseconomics/cic-custodial/internal/actions"
 	tasker_client "github.com/grassrootseconomics/cic-custodial/internal/tasker/client"
 	"github.com/hibiken/asynq"
@@ -47,6 +48,14 @@ func NewTaskerServer(o Opts) *TaskerServer {
 					return asynq.DefaultRetryDelayFunc(n, e, t)
 				}
 			},
+			IsFailure: func(err error) bool {
+				switch err {
+				case redislock.ErrNotObtained:
+					return false
+				default:
+					return true
+				}
+			},
 		},
 	)