class SimpleWorker::LocalWorker

Constants

DEFAULT_CMD

Public Class Methods

new(*args) click to toggle source
# File lib/simpleworker/local_worker.rb, line 7
def initialize(*args)
  cmd = args
  cmd = DEFAULT_CMD if cmd.empty?
  @process = ChildProcess.build(*cmd)
  @process.io.inherit!
end

Public Instance Methods

on_start(jobid) click to toggle source

Start a subprocess with the environment variable 'JOBID' set to the current jobid.

# File lib/simpleworker/local_worker.rb, line 16
def on_start(jobid)
  @process.environment['JOBID'] = jobid
  @process.start
end
on_stop() click to toggle source
# File lib/simpleworker/local_worker.rb, line 21
def on_stop
  @process.stop
end