lib/upperkut/batch_execution.rb in upperkut-0.5.1 vs lib/upperkut/batch_execution.rb in upperkut-0.5.2

- old
+ new

@@ -15,10 +15,10 @@ items_body = items.collect do |item| item['body'] end - @worker.middlewares.invoke(@worker, items) do + @worker.server_middlewares.invoke(@worker, items) do worker_instance.perform(items_body.dup) end rescue Exception => ex @worker.push_items(items_body)