Class: ActiveJob::QueueAdapters::SolidQueueExt::SolidQueueJobs

Inherits:
Object
  • Object
show all
Defined in:
lib/active_job/queue_adapters/solid_queue_ext.rb

Constant Summary collapse

STATUS_MAP = 
{
  pending: :ready,
  failed: :failed,
  in_progress: :claimed,
  blocked: :blocked,
  scheduled: :scheduled,
  finished: :finished
}

Instance Method Summary collapse

Constructor Details

#initialize(jobs_relation) ⇒ SolidQueueJobs

Returns a new instance of SolidQueueJobs.



155
156
157
 
# File 'lib/active_job/queue_adapters/solid_queue_ext.rb', line 155

def initialize(jobs_relation)
  @jobs_relation = jobs_relation
end

Instance Method Details

#count ⇒ Object 



163
164
165
 
# File 'lib/active_job/queue_adapters/solid_queue_ext.rb', line 163

def count
  limit_value_provided? ? direct_count : internally_limited_count
end

#discard_all ⇒ Object 



173
174
175
 
# File 'lib/active_job/queue_adapters/solid_queue_ext.rb', line 173

def discard_all
  execution_class_by_status.discard_all_from_jobs(jobs)
end

#find_job(active_job_id) ⇒ Object 



167
168
169
170
171
 
# File 'lib/active_job/queue_adapters/solid_queue_ext.rb', line 167

def find_job(active_job_id)
  if (job = SolidQueue::Job.where(active_job_id: active_job_id).order(:id).last)
    job if matches_relation_filters?(job)
  end
end

#jobs ⇒ Object 



159
160
161
 
# File 'lib/active_job/queue_adapters/solid_queue_ext.rb', line 159

def jobs
  solid_queue_status.finished? ? order_finished_jobs(finished_jobs) : order_executions(executions).map(&:job).compact
end

#retry_all ⇒ Object 



177
178
179
 
# File 'lib/active_job/queue_adapters/solid_queue_ext.rb', line 177

def retry_all
  SolidQueue::FailedExecution.retry_all(jobs)
end