Class: SolidQueue::FailedExecution

Inherits:
Execution show all
Includes:
Dispatching
Defined in:
lib/solid_queue_mongoid/models/classes.rb,
lib/solid_queue_mongoid/models/failed_execution.rb

Constant Summary

Constants inherited from Record

Record::INDEX_HINTS

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from Execution

create_all_from_jobs, #discard, discard_all_from_jobs, discard_all_in_batches, type, #type

Methods inherited from Record

create_or_find_by!, find_by!, index, index_specifications, index_specifications=, inherited, non_blocking_lock, supports_insert_conflict_target?, transaction, use_index

Instance Attribute Details

#exception ⇒ Object

Returns the value of attribute exception.



9
10
11
 
# File 'lib/solid_queue_mongoid/models/failed_execution.rb', line 9

def exception
  @exception
end

Class Method Details

.retry_all(jobs) ⇒ Object 



16
17
18
19
20
21
 
# File 'lib/solid_queue_mongoid/models/failed_execution.rb', line 16

def retry_all(jobs)
  SolidQueue.instrument(:retry_all, jobs_size: jobs.size) do |payload|
    job_ids = jobs.map(&:id)
    payload[:size] = dispatch_jobs(lock_all_from_jobs_ids(job_ids))
  end
end

Instance Method Details

#retry ⇒ Object 



30
31
32
33
34
35
36
37
38
 
# File 'lib/solid_queue_mongoid/models/failed_execution.rb', line 30

def retry
  SolidQueue.instrument(:retry, job_id: job.id) do
    Mongoid.transaction do
      job.reset_execution_counters
      job.prepare_for_execution
      destroy!
    end
  end
end