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