Method: PerfectQueue::TaskMonitor#set_task

Defined in:
lib/perfectqueue/task_monitor.rb

#set_task(task, runner) ⇒ Object 



55
56
57
58
59
60
61
62
63
64
 
# File 'lib/perfectqueue/task_monitor.rb', line 55

def set_task(task, runner)
  task.extend(TaskMonitorHook)
  task.log = @log
  task.task_monitor = self
  task.runner = runner
  @mutex.synchronize {
    @task = task
    @last_task_heartbeat = Time.now.to_i
  }
end