Class: ResqueWeb::Plugins::ResqueScheduler::JobFinder::WorkingJobFinder

Inherits:
Object
  • Object
show all
Defined in:
app/models/resque_web/plugins/resque_scheduler/job_finder/working_job_finder.rb

Overview

This class finds working jobs that Resque is currently processing

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(search_term) ⇒ WorkingJobFinder

The search term will be used to match against the class name of any jobs that are currently being processed by any of the workers.

Parameters:

  • search_term (String) 


14
15
16
 
# File 'app/models/resque_web/plugins/resque_scheduler/job_finder/working_job_finder.rb', line 14

def initialize(search_term)
  @search_term = search_term
end

Instance Attribute Details

#search_term ⇒ Object

The terms that the user entered.



8
9
10
 
# File 'app/models/resque_web/plugins/resque_scheduler/job_finder/working_job_finder.rb', line 8

def search_term
  @search_term
end

Instance Method Details

#find_jobs ⇒ Array

Finds all jobs that match the search term provided when the class was instantiated.

[

{
  'class' => 'SomeClass',
  'queue' => 'some_queue',
  'where_at' => 'working'
}

]

Returns:

  • (Array) —

    Returns an array of hashes.



31
32
33
34
35
36
37
38
 
# File 'app/models/resque_web/plugins/resque_scheduler/job_finder/working_job_finder.rb', line 31

def find_jobs
  workers_with_jobs_that_match_search_term.map do |w|
    w.job['payload'].merge(
      'queue' => w.job['queue'],
      'where_at' => 'working'
    )
  end
end