Sha256: df49578f4a7400e59ff776c4a441fb30ad1e2a3a8b25a3c16c2846dcf91f5eb7
Contents?: true
Size: 748 Bytes
Versions: 3
Compression:
Stored size: 748 Bytes
Contents
require_relative 'logging' module Upperkut class BatchExecution include Upperkut::Util def initialize(worker, logger = Upperkut::Logging.logger) @worker = worker @logger = logger end def execute worker_instance = @worker.new items = @worker.fetch_items.freeze items_body = items.collect do |item| item['body'] end @worker.server_middlewares.invoke(@worker, items) do worker_instance.perform(items_body.dup) end rescue Exception => ex @worker.push_items(items_body) @logger.info( action: :requeue, ex: ex, item_size: items_body.size ) @logger.error(ex.backtrace.join("\n")) raise ex end end end
Version data entries
3 entries across 3 versions & 1 rubygems
Version | Path |
---|---|
upperkut-0.7.0 | lib/upperkut/batch_execution.rb |
upperkut-0.6.0 | lib/upperkut/batch_execution.rb |
upperkut-0.5.2 | lib/upperkut/batch_execution.rb |