Sha256: 20fda9ee9cad0fec92bd7112fe8fd937cc465cb2ce4c70878db24c750b2da243
Contents?: true
Size: 754 Bytes
Versions: 17
Compression:
Stored size: 754 Bytes
Contents
module CanvasSync::JobUniqueness
class Configuration
include ActiveSupport::Configurable
config_accessor(:lock_ttl) { 14.days.to_i }
config_accessor(:lock_prefix) { 'uniquejob' }
config_accessor(:on_conflict) { :raise }
config_accessor(:lock_strategies) { {} }
config_accessor(:conflict_strategies) { {} }
config_accessor(:redis_version) { nil }
def on_conflict=(action)
validate_on_conflict_action!(action)
config.on_conflict = action
end
def validate_on_conflict_action!(action)
return if action.nil? || %i[log raise].include?(action) || action.respond_to?(:call)
raise ActiveJob::Uniqueness::InvalidOnConflictAction, "Unexpected '#{action}' action on conflict"
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems