From a5b704c4e3f073a6a24bb1d47c2cd6e918d88be2 Mon Sep 17 00:00:00 2001
From: hageshtrem <hageshtrem@yahoo.com>
Date: Fri, 7 Jul 2023 21:31:28 +0300
Subject: [PATCH] Fix forward condition

---
 redis.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/redis.go b/redis.go
index b63cc8de..b008e3e2 100644
--- a/redis.go
+++ b/redis.go
@@ -190,7 +190,7 @@ local lockKey = KEYS[2]
 local lockInfoKey = KEYS[3]
 local workerPoolID = ARGV[1]
 local job = ARGV[2]
-local forward = ARGV[3]
+local forward = ARGV[3] == '1'
 local result = tonumber(redis.call('lrem', inProgQueue, 1, job))
 
 if result ~= 0 then