Class: Job

Inherits:
Object
  • Object
show all
Defined in:
lib/gorgon/job.rb

Instance Method Summary collapse

Constructor Details

#initialize(listener, job_definition) ⇒ Job

Returns a new instance of Job.



2
3
4
5
 
# File 'lib/gorgon/job.rb', line 2

def initialize(listener, job_definition)
  @workers = []
  @definition = job_definition
end

Instance Method Details

#add_worker ⇒ Object 



9
10
11
 
# File 'lib/gorgon/job.rb', line 9

def add_worker

end

#on_worker_complete ⇒ Object 



13
14
15
16
 
# File 'lib/gorgon/job.rb', line 13

def on_worker_complete
  @available_worker_slots += 1
  on_current_job_complete if current_job_complete?
end

#setup_child_process ⇒ Object 



18
19
20
21
22
23
24
25
 
# File 'lib/gorgon/job.rb', line 18

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
end