Contents

require 'barbeque_client/exponential_retry'

module BarbequeClient
  module Retryable
    extend ActiveSupport::Concern

    class EmptyRetryCount < StandardError; end

    module ClassMethods
      def barbeque_retry(limit:, retryable_exceptions: nil)
        exceptions = Array.wrap(retryable_exceptions || StandardError)

        rescue_from *exceptions do |exception|
          unless ENV['BARBEQUE_RETRY_COUNT']
            raise EmptyRetryCount.new('ENV["BARBEQUE_RETRY_COUNT"] is not set')
          end
          count = ENV['BARBEQUE_RETRY_COUNT'].to_i

          if count < limit
            ExponentialRetry.new(count).retry(self.job_id)
          else
            raise exception
          end
        end
      end
    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
barbeque_client-0.11.0	lib/barbeque_client/retryable.rb
barbeque_client-0.10.2	lib/barbeque_client/retryable.rb
barbeque_client-0.10.1	lib/barbeque_client/retryable.rb
barbeque_client-0.10.0	lib/barbeque_client/retryable.rb
barbeque_client-0.9.1	lib/barbeque_client/retryable.rb
barbeque_client-0.9.0	lib/barbeque_client/retryable.rb
barbeque_client-0.8.2	lib/barbeque_client/retryable.rb
barbeque_client-0.8.1	lib/barbeque_client/retryable.rb
barbeque_client-0.8.0	lib/barbeque_client/retryable.rb