class Maxwell::Agent::Worker

Public Instance Methods

perform(work) click to toggle source
# File lib/maxwell/agent/worker.rb, line 5
def perform(work)
  work.perform

  post_run(work)
ensure
  work_schedule.put_back(work)
end
work_schedule() click to toggle source
# File lib/maxwell/agent/worker.rb, line 13
def work_schedule
  Agent.runner[:work_schedule]
end

Private Instance Methods

post_run(work) click to toggle source
# File lib/maxwell/agent/worker.rb, line 19
def post_run(work)
  work.perform_at = nil
  work.last_run = Time.now

  Agent.runner[:middleware_runner].inoke(work)
end