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

Version	Path
gorgon-0.3.0	lib/gorgon/job.rb
gorgon-0.2.0	lib/gorgon/job.rb
gorgon-0.1.1	lib/gorgon/job.rb
gorgon-0.1.0	lib/gorgon/job.rb
gorgon-0.0.2	lib/gorgon/job.rb
gorgon-0.0.1	lib/gorgon/job.rb