Merge pull request #3615 from 3scale/fix-serialization-for-zync-worke…

…r-args

Fix serialization of ZyncWorker arguments

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

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