fix: minor ack bug on redis (#463)

geofmureithi · Nov 28, 2024 · 094938d · 094938d
1 parent 55d319f
commit 094938d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git 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
@@ -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