class Delayed::JobGroups::Plugin

Public Class Methods

job_acceptably_failed?(job) click to toggle source
# File lib/delayed/job_groups/plugin.rb, line 47
def self.job_acceptably_failed?(job)
  # Job has set failed_at (retries have maxed out) and failure_cancels_group is false signaling
  # that the group should complete despite failures.
  job.failed_at.present? && job.job_group.present? && !job.job_group.failure_cancels_group?
end
job_completed?(job) click to toggle source
# File lib/delayed/job_groups/plugin.rb, line 41
def self.job_completed?(job)
  # Delayed job will already have marked the job for destruction
  # if it has completed
  job.destroyed?
end
job_group_cancelled?(job_group_id) click to toggle source
# File lib/delayed/job_groups/plugin.rb, line 37
def self.job_group_cancelled?(job_group_id)
  !JobGroup.exists?(job_group_id)
end