(self)
Adds a new process (L{Instance} to the Dataflow pool.

        Creates a new L{Instance} and runs it inside a L{multiprocessing.Process}
Adds a new process (L{Instance} to the Dataflow pool.
Adds a new process ( L { Instance } to the Dataflow pool .
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()
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 ( )