lib/gorgon/job.rb in gorgon-0.11.0 vs lib/gorgon/job.rb in gorgon-0.11.1

- old
+ new

@@ -1,26 +1,28 @@ -class Job - def initialize(listener, job_definition) - @workers = [] - @definition = job_definition - end +module Gorgon + class Job + def initialize(listener, job_definition) + @workers = [] + @definition = job_definition + end - def add_worker + def add_worker - end + end - def on_worker_complete - @available_worker_slots += 1 - on_current_job_complete if current_job_complete? - end + def on_worker_complete + @available_worker_slots += 1 + on_current_job_complete if current_job_complete? + end - def setup_child_process - worker = ChildProcess.build("gorgon", "work", @worker_communication.name, @config_filename) + def setup_child_process + worker = ChildProcess.build("gorgon", "work", @worker_communication.name, @config_filename) - worker_output = Tempfile.new("gorgon-worker") - worker.io.stdout = worker_output - worker.io.stderr = worker_output - worker + worker_output = Tempfile.new("gorgon-worker") + worker.io.stdout = worker_output + worker.io.stderr = worker_output + worker + end end end