  
      def _add_queues(self):
          """ Add the required processing queues to Queue Manager """
          queues = dict()
          tasks = []
          tasks = ["extract_{}_in".format(phase) for phase in self._flow]
          tasks.append("extract_{}_out".format(self._final_phase))
          for task in tasks:
              # Limit queue size to avoid stacking ram
              queue_manager.add_queue(task, maxsize=self._queue_size)
              queues[task] = queue_manager.get_queue(task)
          logger.debug("Queues: %s", queues)
 
</s> remove                 name="{}_{}".format(self._plugin_type, q_name),
 </s> add                 name="{}{}_{}".format(self._plugin_type, self._instance, q_name), </s> remove             qname = "extract_{}_out".format(self._final_phase)
 </s> add             qname = "extract{}_{}_out".format(self._instance, self._final_phase) </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])
        tasks = ["extract{}_{}_in".format(self._instance, phase) for phase in self._flow]
        tasks.append("extract{}_{}_out".format(self._instance, self._final_phase))
  
      def _add_queues(self):
          """ Add the required processing queues to Queue Manager """
          queues = dict()
        tasks = ["extract{}_{}_in".format(self._instance, phase) for phase in self._flow]
        tasks.append("extract{}_{}_out".format(self._instance, self._final_phase))
        tasks = ["extract{}_{}_in".format(self._instance, phase) for phase in self._flow]
        tasks.append("extract{}_{}_out".format(self._instance, self._final_phase))
        tasks = ["extract{}_{}_in".format(self._instance, phase) for phase in self._flow]
        tasks.append("extract{}_{}_out".format(self._instance, self._final_phase))
          for task in tasks:
              # Limit queue size to avoid stacking ram
              queue_manager.add_queue(task, maxsize=self._queue_size)
              queues[task] = queue_manager.get_queue(task)
          logger.debug("Queues: %s", queues)
keep keep keep keep replace replace replace keep keep keep keep keep
 Extract - Allow multiple pipelines to be loaded 
plugins/extract/pipeline.py