lib/sidekiq/testing.rb in sidekiq-7.1.4 vs lib/sidekiq/testing.rb in sidekiq-7.1.5
- old
+ new
@@ -62,10 +62,10 @@
Sidekiq::Testing.fake!
class EmptyQueueError < RuntimeError; end
module TestingClient
- def raw_push(payloads)
+ def atomic_push(conn, payloads)
if Sidekiq::Testing.fake?
payloads.each do |job|
job = Sidekiq.load_json(Sidekiq.dump_json(job))
job["enqueued_at"] = Time.now.to_f unless job["at"]
Queues.push(job["queue"], job["class"], job)