Sha256: 9fdab738b7e168f5cff0f5945ed03105790b64604a177efeca884829d8564f93
Contents?: true
Size: 779 Bytes
Versions: 34
Compression:
Stored size: 779 Bytes
Contents
# frozen_string_literal: true
module CI
module Queue
module Common
attr_reader :config
# to override in classes including this module
CONNECTION_ERRORS = [].freeze
def distributed?
raise NotImplementedError
end
def retrying?
false
end
def release!
# noop
end
def flaky?(test)
@config.flaky?(test)
end
def report_failure!
config.circuit_breakers.each(&:report_failure!)
end
def report_success!
config.circuit_breakers.each(&:report_success!)
end
def rescue_connection_errors(handler = ->(err) { nil })
yield
rescue *self::class::CONNECTION_ERRORS => err
handler.call(err)
end
end
end
end
Version data entries
34 entries across 34 versions & 1 rubygems