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