Update lib/active_job/queue_adapters/resque_ext.rb

Co-authored-by: Rosa Gutierrez <[email protected]>
rails · Apr 3, 2024 · 923d5cc · 923d5cc
1 parent 3daa89c
commit 923d5cc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/active_job/queue_adapters/resque_ext.rb b/lib/active_job/queue_adapters/resque_ext.rb
@@ -261,7 +261,7 @@ def requeue(job)
           resque_job = job.raw_data
           resque_job["retried_at"] = Time.now.strftime("%Y/%m/%d %H:%M:%S")
 
-          redis.lset(queue_redis_key, job.position, resque_job.to_json)
+          redis.lset(queue_redis_key, job.position, Resque.encode(resque_job))
           Resque::Job.create(resque_job["queue"], resque_job["payload"]["class"], *resque_job["payload"]["args"])
         rescue Redis::CommandError => error
           handle_resque_job_error(job, error)