code: def enqueue(self, pipeline):
          
          copied = Pipeline().append(pipeline)
          copied.group = self
          self._queue.put(copied)
docs: Start a pipeline.
  
          :param pipeline: Start this pipeline.