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')