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