class Bricolage::StreamingLoad::Job::ControlConnection::TaskInfo
Public Instance Methods
failure_count()
click to toggle source
# File lib/bricolage/streamingload/job.rb, line 308 def failure_count @failure_count ||= begin statuses = jobs.map(&:status) statuses.delete('duplicated') last_succ = statuses.rindex('success') statuses[0..last_succ] = [] if last_succ statuses.size end end
fix_last_job_status(st)
click to toggle source
# File lib/bricolage/streamingload/job.rb, line 304 def fix_last_job_status(st) jobs.last.status = st unless jobs.empty? end
last_job_id()
click to toggle source
# File lib/bricolage/streamingload/job.rb, line 299 def last_job_id return nil if jobs.empty? jobs.last.job_id end
unknown_state?()
click to toggle source
# File lib/bricolage/streamingload/job.rb, line 294 def unknown_state? return false if jobs.empty? jobs.last.status == 'unknown' end