      @property
      def _output_queue(self):
          """ Return the correct output queue depending on the current phase """
          if self.final_pass:
              qname = "extract_{}_out".format(self._final_phase)
          else:
              qname = "extract_{}_in".format(self._phases[self._phase_index + 1][0])
          retval = self._queues[qname]
          logger.trace("%s: %s", qname, retval)
          return retval
 
</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_{}_in".format(self._current_phase[0])
 </s> add         qname = "extract{}_{}_in".format(self._instance, self._current_phase[0]) </s> remove         in_qname = "extract_{}_in".format(phase)
 </s> add         in_qname = "extract{}_{}_in".format(self._instance, phase) </s> remove             out_qname = "extract_{}_out".format(self._final_phase)
 </s> add             out_qname = "extract{}_{}_out".format(self._instance, self._final_phase) </s> remove             out_qname = "extract_{}_in".format(next_phase)
 </s> add             out_qname = "extract{}_{}_in".format(self._instance, next_phase)
            qname = "extract{}_{}_out".format(self._instance, self._final_phase)
      @property
      def _output_queue(self):
          """ Return the correct output queue depending on the current phase """
          if self.final_pass:
            qname = "extract{}_{}_out".format(self._instance, self._final_phase)
          else:
              qname = "extract_{}_in".format(self._phases[self._phase_index + 1][0])
          retval = self._queues[qname]
          logger.trace("%s: %s", qname, retval)
          return retval
keep keep keep keep replace keep keep keep keep keep
 Extract - Allow multiple pipelines to be loaded 
plugins/extract/pipeline.py