From 094938d95f7ad90caab9edfc9fd04368fbcbe193 Mon Sep 17 00:00:00 2001
From: Geoffrey Mureithi <95377562+geofmureithi@users.noreply.github.com>
Date: Thu, 28 Nov 2024 10:04:08 +0300
Subject: [PATCH] fix: minor ack bug on redis (#463)

---
 packages/apalis-redis/lua/retry_job.lua | 2 +-
 packages/apalis-redis/src/storage.rs    | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/packages/apalis-redis/lua/retry_job.lua b/packages/apalis-redis/lua/retry_job.lua
index e3df0e76..477bf2b2 100644
--- a/packages/apalis-redis/lua/retry_job.lua
+++ b/packages/apalis-redis/lua/retry_job.lua
@@ -22,7 +22,7 @@ if removed == 1 then
 
   -- Save the result of the job
   local ns = "::result"
-  redis.call("hmset", KEYS[3].. ns, ARGV[1], ARGV[4] )
+  redis.call("hmset", KEYS[3] .. ns, ARGV[1], ARGV[3] )
 
 end
 
diff --git a/packages/apalis-redis/src/storage.rs b/packages/apalis-redis/src/storage.rs
index e335c217..c5f5feef 100644
--- a/packages/apalis-redis/src/storage.rs
+++ b/packages/apalis-redis/src/storage.rs
@@ -566,6 +566,7 @@ where
                         .await
                 }
                 _ => {
+                    // TODO: Increase the attempts
                     let retry_job = self.scripts.retry_job.clone();
                     let retry_jobs_set = &self.config.scheduled_jobs_set();
                     retry_job