          self._queues["in"] = in_queue
          self._queues["out"] = out_queue
          for q_name in queues:
              self._queues[q_name] = queue_manager.get_queue(
                  name="{}_{}".format(self._plugin_type, q_name),
                  maxsize=self.queue_size)
  
      # <<< THREAD METHODS >>> #
      def _compile_threads(self):
          """ Compile the threads into self._threads list """
 
</s> remove         tasks = []
        tasks = ["extract_{}_in".format(phase) for phase in self._flow]
        tasks.append("extract_{}_out".format(self._final_phase))
 </s> add         tasks = ["extract{}_{}_in".format(self._instance, phase) for phase in self._flow]
        tasks.append("extract{}_{}_out".format(self._instance, self._final_phase)) </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])
                name="{}{}_{}".format(self._plugin_type, self._instance, q_name),
          self._queues["in"] = in_queue
          self._queues["out"] = out_queue
          for q_name in queues:
              self._queues[q_name] = queue_manager.get_queue(
                name="{}{}_{}".format(self._plugin_type, self._instance, q_name),
                  maxsize=self.queue_size)
  
      # <<< THREAD METHODS >>> #
      def _compile_threads(self):
          """ Compile the threads into self._threads list """
keep keep keep keep replace keep keep keep keep keep
 Extract - Allow multiple pipelines to be loaded 
plugins/extract/_base.py