              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])
  
          plugin = getattr(self, "_{}".format(phase))
          plugin.initialize(**kwargs)
          plugin.start()
          logger.debug("Launched %s plugin", phase)
  
      def _set_extractor_batchsize(self):
 
</s> remove         logger.info("sample filename: %s, base filename: %s", sample_filename, basename)
 </s> add         logger.debug("sample filename: %s, base filename: %s", sample_filename, basename) </s> remove                          self._queues["post"],
 </s> add                          self._queues["post_{}".format(name)], </s> remove         self._add_queues(kwargs["in_queue"], kwargs["out_queue"], ["predict", "post"])
 </s> add         name = self.name.replace(" ", "_").lower()
        self._add_queues(kwargs["in_queue"],
                         kwargs["out_queue"],
                         ["predict_{}".format(name), "post_{}".format(name)]) </s> remove         The normalization method is dictated by the command line argument `-nh (--normalization)`
 </s> add         The normalization method is dictated by the normalization command line argument
        plugin_type, idx = self._get_plugin_type_and_index(phase)
        plugin = getattr(self, "_{}".format(plugin_type))
        plugin = plugin[idx] if idx is not None else plugin
              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])
  
        plugin_type, idx = self._get_plugin_type_and_index(phase)
        plugin = getattr(self, "_{}".format(plugin_type))
        plugin = plugin[idx] if idx is not None else plugin
          plugin.initialize(**kwargs)
          plugin.start()
          logger.debug("Launched %s plugin", phase)
  
      def _set_extractor_batchsize(self):
keep keep keep keep replace keep keep keep keep keep
 Extraction - Auto generate Components and Extended Masks 
plugins/extract/pipeline.py