Sha256: 6414827073298b30de2fce2bb08779c76040c90e38c67498276c77c6d21ab759
Contents?: true
Size: 1.86 KB
Versions: 18
Compression:
Stored size: 1.86 KB
Contents
class Kuroko2::Token < Kuroko2::ApplicationRecord
include Kuroko2::TableNameCustomizable
WORKING = 0
FINISHED = 1
FAILURE = 2
WAITING = 3
CRITICAL = 9
STATUSES = {
WORKING => :working,
FINISHED => :finished,
FAILURE => :failure,
CRITICAL => :critical,
WAITING => :waiting,
}.freeze
serialize :context, JSON
belongs_to :job_definition
belongs_to :job_instance
has_many :children, class_name: 'Token', foreign_key: 'parent_id', dependent: :destroy
belongs_to :parent, class_name: 'Token', optional: true
has_one :execution
before_create :set_default_values
scope :processable, -> { where(status: [WORKING, WAITING])}
scope :working, -> { where(status: WORKING) }
scope :finished, -> { where(status: FINISHED) }
scope :waiting, -> { where(status: WAITING) }
def working?
status == WORKING
end
def failure?
status == FAILURE
end
def finished?
status == FINISHED
end
def critical?
status == CRITICAL
end
def waiting?
status == WAITING
end
def mark_as_failure
self.status = FAILURE
end
def mark_as_critical(error)
self.status = CRITICAL
self.message = error.message
end
def mark_as_finished
self.status = FINISHED
end
def mark_as_working
self.status = WORKING
end
def mark_as_waiting
self.status = WAITING
end
def status_name
STATUSES[status].to_s
end
def cancelable?
case status
when WORKING, WAITING
children.many? && children.all? do |child|
child.status == FINISHED || child.cancelable?
end
when FAILURE
true
else
false
end
end
def skippable?
failure? || waiting?
end
def retryable?
failure?
end
private
def set_default_values
self.uuid ||= SecureRandom.uuid
self.message ||= ''
self.context ||= {}
self.status ||= WORKING
end
end
Version data entries
18 entries across 18 versions & 1 rubygems