Class: ResqueWeb::Plugins::ResqueScheduler::JobFinder::WorkingJobFinder
- Inherits:
-
Object
- Object
- ResqueWeb::Plugins::ResqueScheduler::JobFinder::WorkingJobFinder
- 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
-
#search_term ⇒ Object
The terms that the user entered.
Instance Method Summary collapse
-
#find_jobs ⇒ Array
Finds all jobs that match the search term provided when the class was instantiated.
-
#initialize(search_term) ⇒ WorkingJobFinder
constructor
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.
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.
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'
}
]
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 |