parameters: (self)
docstring: Adds a new process (L{Instance} to the Dataflow pool.
  
          Creates a new L{Instance} and runs it inside a L{multiprocessing.Process}
docstring_summary: Adds a new process (L{Instance} to the Dataflow pool.
docstring_tokens: Adds a new process ( L { Instance } to the Dataflow pool .
function: def add_process(self):
          """Adds a new process (L{Instance} to the Dataflow pool.
  
          Creates a new L{Instance} and runs it inside a L{multiprocessing.Process}
          """
          process = Instance(self.queue)
          self.processes.append(process)
          Process(target=process.send).start()
          Process(target=process.execute, args=(self.pipeline,)).start()
function_tokens: def add_process ( self ) : process = Instance ( self . queue ) self . processes . append ( process ) Process ( target = process . send ) . start ( ) Process ( target = process . execute , args = ( self . pipeline , ) ) . start ( )