          """ Launch an extraction plugin """
          logger.debug("Launching %s plugin", phase)
          in_qname = "extract_{}_in".format(phase)
          if phase == self._final_phase:
              out_qname = "extract_{}_out".format(self._final_phase)
          else:
              next_phase = self._flow[self._flow.index(phase) + 1]
              out_qname = "extract_{}_in".format(next_phase)
          logger.debug("in_qname: %s, out_qname: %s", in_qname, out_qname)
          kwargs = dict(in_queue=self._queues[in_qname], out_queue=self._queues[out_qname])
 
</s> remove         in_qname = "extract_{}_in".format(phase)
 </s> add         in_qname = "extract{}_{}_in".format(self._instance, phase) </s> remove             out_qname = "extract_{}_in".format(next_phase)
 </s> add             out_qname = "extract{}_{}_in".format(self._instance, next_phase) </s> remove                                                       configfile=configfile)
 </s> add                                                       configfile=configfile,
                                                      instance=self._instance) </s> remove             qname = "extract_{}_in".format(self._phases[self._phase_index + 1][0])
 </s> add             qname = "extract{}_{}_in".format(self._instance,
                                             self._phases[self._phase_index + 1][0]) </s> remove             qname = "extract_{}_out".format(self._final_phase)
 </s> add             qname = "extract{}_{}_out".format(self._instance, self._final_phase)
            out_qname = "extract{}_{}_out".format(self._instance, self._final_phase)
          """ Launch an extraction plugin """
          logger.debug("Launching %s plugin", phase)
          in_qname = "extract_{}_in".format(phase)
          if phase == self._final_phase:
            out_qname = "extract{}_{}_out".format(self._instance, self._final_phase)
          else:
              next_phase = self._flow[self._flow.index(phase) + 1]
              out_qname = "extract_{}_in".format(next_phase)
          logger.debug("in_qname: %s, out_qname: %s", in_qname, out_qname)
          kwargs = dict(in_queue=self._queues[in_qname], out_queue=self._queues[out_qname])
keep keep keep keep replace keep keep keep keep keep
 Extract - Allow multiple pipelines to be loaded 
plugins/extract/pipeline.py