Class: Sidekiq::Monitor::Processor
- Inherits:
-
Object
- Object
- Sidekiq::Monitor::Processor
- Defined in:
- lib/sidekiq/monitor/processor.rb
Instance Method Summary collapse
- #complete(worker, item, queue, return_value) ⇒ Object
- #error(worker, item, queue, exception) ⇒ Object
- #queue(worker_class, item, queue) ⇒ Object
- #start(worker, item, queue) ⇒ Object
Instance Method Details
#complete(worker, item, queue, return_value) ⇒ Object
22 23 24 25 26 27 28 29 |
# File 'lib/sidekiq/monitor/processor.rb', line 22 def complete(worker, item, queue, return_value) job = find_or_initialize_job(worker, item, queue) job.update_attributes( finished_at: DateTime.now, status: 'complete', result: (return_value if return_value.is_a?(Hash)) ) end |
#error(worker, item, queue, exception) ⇒ Object
17 18 19 20 |
# File 'lib/sidekiq/monitor/processor.rb', line 17 def error(worker, item, queue, exception) job = find_or_initialize_job(worker, item, queue) set_error(job, exception) end |
#queue(worker_class, item, queue) ⇒ Object
4 5 6 7 |
# File 'lib/sidekiq/monitor/processor.rb', line 4 def queue(worker_class, item, queue) job = find_or_initialize_job(worker_class, item, queue) job.save end |
#start(worker, item, queue) ⇒ Object
9 10 11 12 13 14 15 |
# File 'lib/sidekiq/monitor/processor.rb', line 9 def start(worker, item, queue) job = find_or_initialize_job(worker, item, queue) job.update_attributes( started_at: DateTime.now, status: 'running' ) end |