lib/backburner.rb in backburner-allq-1.0.31 vs lib/backburner.rb in backburner-allq-1.0.32

- old
+ new

@@ -22,12 +22,14 @@ # Enqueues a job to be performed with given arguments. # # @example # Backburner.enqueue NewsletterSender, self.id, user.id # - def enqueue(job_class, args, shard_key: nil) - Backburner::Worker.enqueue(job_class, args, { shard_key: shard_key.nil? ? "X" : shard_key.to_s }) + def enqueue(job_class, args, opts={}) + opts[:shard_key] = opts[:shard_key] ? "X" : opts[:shard_key].to_s + Backburner::Worker.enqueue(job_class, args, opts) end + # Begins working on jobs enqueued with optional tubes specified # # @example # Backburner.work('newsletter_sender', 'test_job')