From ac1619104999c0d193ebe8ab01c260984656d657 Mon Sep 17 00:00:00 2001 From: Daria Mayorova Date: Wed, 8 Nov 2023 16:57:54 +0100 Subject: [PATCH] Fix serialization of ZyncWorker arguments --- app/workers/zync_worker.rb | 2 +- test/workers/zync_worker_test.rb | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/app/workers/zync_worker.rb b/app/workers/zync_worker.rb index 455d2f5b0a..1546ce9e98 100644 --- a/app/workers/zync_worker.rb +++ b/app/workers/zync_worker.rb @@ -139,7 +139,7 @@ def on_complete(_bid, options) # The number of retries is usually controlled at the origin of the failure using ThreeScale::SidekiqRetrySupport::Worker#last_attempt?, # but in this case we are not really using Sidekiq retries, but rather re-enqueueing the job manually here manual_retry_count = options['manual_retry_count'].to_i + 1 - perform_async(event.event_id, event.data.to_json, manual_retry_count) + perform_async(event.event_id, event.data.as_json, manual_retry_count) end delegate :perform_async, to: :class diff --git a/test/workers/zync_worker_test.rb b/test/workers/zync_worker_test.rb index f075920d31..60d5acb53b 100644 --- a/test/workers/zync_worker_test.rb +++ b/test/workers/zync_worker_test.rb @@ -124,7 +124,7 @@ class UnprocessableEntityRetryTest < ActiveSupport::TestCase test 'on batch complete' do event_id = event.event_id klass = worker.class - klass.expects(:perform_async).with(event_id, anything, 1) + klass.expects(:perform_async).with(event_id, event.data.as_json, 1) klass.new.on_complete(1, {'event_id' => event_id, 'manual_retry_count' => 0}) end