lib/upperkut/processor.rb in upperkut-1.0.0.rc vs lib/upperkut/processor.rb in upperkut-1.0.2
- old
+ new
@@ -9,9 +9,10 @@
@logger = logger
end
def process
items = @worker.fetch_items.freeze
+ return unless items.any?
@worker.server_middlewares.invoke(@worker, items) do
@worker_instance.perform(items)
end