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
+				}
+			},
 		},
 	)