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)