Contents

module Executrix
  class Batch
    def initialize connection, job_id, batch_id
      @connection = connection
      @job_id = job_id
      @batch_id = batch_id

      if @batch_id == -1
        @final_status = {
          state: 'Completed',
          state_message: 'Empty Request'
        }
      end
    end

    def final_status poll_interval=2
      return @final_status if @final_status

      @final_status = self.status
      while ['Queued', 'InProgress'].include?(@final_status[:state])
        sleep poll_interval
        @final_status = self.status
        yield @final_status if block_given?
      end

      raise @final_status[:state_message] if @final_status[:state] == 'Failed'

      @final_status.merge({
          results: results
        })
    end

    def status
      @connection.query_batch @job_id, @batch_id
    end

    # only needed for query
    def init_result_id
      max_retries = 5
      retry_count = 0
      while @result_id.nil? && retry_count < max_retries
        @result_id = @connection.query_batch_result_id(@job_id, @batch_id)[:result]
        retry_count += 1
      end
    end

    def results
      @connection.query_batch_result_data(@job_id, @batch_id, @result_id)
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
executrix-1.1.2	lib/executrix/batch.rb
executrix-1.1.1	lib/executrix/batch.rb
executrix-1.1.0	lib/executrix/batch.rb
executrix-1.0.0	lib/executrix/batch.rb