Sha256: f205fa7016bbb1139a4cfd34392d64e25a93e8e93b28ebffc1751992126d0592
Contents?: true
Size: 1.23 KB
Versions: 7
Compression:
Stored size: 1.23 KB
Contents
# frozen_string_literal: true
module GoodJob
# Shared methods for filtering Execution/Job records from the +good_jobs+ table.
module ErrorEvents
extend ActiveSupport::Concern
ERROR_EVENTS = [
ERROR_EVENT_INTERRUPTED = 'interrupted',
ERROR_EVENT_UNHANDLED = 'unhandled',
ERROR_EVENT_HANDLED = 'handled',
ERROR_EVENT_RETRIED = 'retried',
ERROR_EVENT_RETRY_STOPPED = 'retry_stopped',
ERROR_EVENT_DISCARDED = 'discarded',
].freeze
ERROR_EVENT_ENUMS = {
ERROR_EVENT_INTERRUPTED => 0,
ERROR_EVENT_UNHANDLED => 1,
ERROR_EVENT_HANDLED => 2,
ERROR_EVENT_RETRIED => 3,
ERROR_EVENT_RETRY_STOPPED => 4,
ERROR_EVENT_DISCARDED => 5,
}.freeze
# TODO: GoodJob v4 can make this an `enum` once migrations are guaranteed.
def error_event
return unless self.class.columns_hash['error_event']
enum = read_attribute(:error_event)
return unless enum
ERROR_EVENT_ENUMS.key(enum)
end
def error_event=(event)
return unless self.class.columns_hash['error_event']
enum = ERROR_EVENT_ENUMS[event]
raise(ArgumentError, "Invalid error_event: #{event}") if event && !enum
write_attribute(:error_event, enum)
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems