def METHOD_NAME(self):
    p = self.pipeline()
    names = p.process_names()
    for name in names:
        proc = p.process_by_name(name)
        thread = threading.Thread(target=self._run_process, name=name, args=(proc,))
        self._threads.append(thread)
    for thread in self._threads:
        thread.start()