Class: Delayed::JobGroups::Plugin

Inherits:
Plugin
  • Object
show all
Defined in:
lib/delayed/job_groups/plugin.rb

Class Method Summary collapse

Class Method Details

.job_acceptably_failed?(job) ⇒ Boolean

Returns:

  • (Boolean) 


49
50
51
52
53
 
# File 'lib/delayed/job_groups/plugin.rb', line 49

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) ⇒ Boolean

Returns:

  • (Boolean) 


43
44
45
46
47
 
# File 'lib/delayed/job_groups/plugin.rb', line 43

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) ⇒ Boolean

Returns:

  • (Boolean) 


39
40
41
 
# File 'lib/delayed/job_groups/plugin.rb', line 39

def self.job_group_cancelled?(job_group_id)
  !JobGroup.exists?(job_group_id)
end