1
0
Fork 0
mirror of https://github.com/mperham/sidekiq.git synced 2022-11-09 13:52:34 -05:00
This commit is contained in:
Mike Perham 2020-05-26 11:03:17 -07:00
parent a1805e36a0
commit 5d831cca38

View file

@ -91,7 +91,7 @@ module Sidekiq
# than the number given if the middleware stopped processing for one or more jobs.
def push_bulk(items)
args = items["args"]
raise ArgumentError, "Bulk arguments must be an Array of Arrays: [[1], [2]]" unless (args.is_a?(Array) && args.all?(Array))
raise ArgumentError, "Bulk arguments must be an Array of Arrays: [[1], [2]]" unless args.is_a?(Array) && args.all?(Array)
return [] if args.empty? # no jobs to push
at = items.delete("at")