From 923d5cc9941d31e6c7a3f78536dd3fa81fc6eeb0 Mon Sep 17 00:00:00 2001 From: Alexandre Chakroun <11556013+alxckn@users.noreply.github.com> Date: Wed, 3 Apr 2024 18:25:08 +0200 Subject: [PATCH] Update lib/active_job/queue_adapters/resque_ext.rb Co-authored-by: Rosa Gutierrez --- lib/active_job/queue_adapters/resque_ext.rb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/active_job/queue_adapters/resque_ext.rb b/lib/active_job/queue_adapters/resque_ext.rb index 1d0c69f6..2bb9ab2f 100644 --- 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)