Sha256: 7fab2d8bde135fd77caca8192568be82c7cedd0f63d5ef0927edd0d0045bb2f8
Contents?: true
Size: 524 Bytes
Versions: 46
Compression:
Stored size: 524 Bytes
Contents
class Job
def initialize(listener, job_definition)
@workers = []
@definition = job_definition
end
def add_worker
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)
worker_output = Tempfile.new("gorgon-worker")
worker.io.stdout = worker_output
worker.io.stderr = worker_output
worker
end
end
Version data entries
46 entries across 46 versions & 1 rubygems