Contents

require_relative 'logging'

module Upperkut
  class BatchExecution
    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.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
      )

      raise ex
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
upperkut-0.4.1	lib/upperkut/batch_execution.rb
upperkut-0.4.0	lib/upperkut/batch_execution.rb