                      self.name, self._plugin_type, self.batchsize)
  
      def _add_queues(self, in_queue, out_queue, queues):
          """ Add the queues
              in_queue and out_queue should be pre-created queue manager queues
              queues should be a list of queue names """
          self._queues["in"] = in_queue
          self._queues["out"] = out_queue
          for q_name in queues:
              self._queues[q_name] = queue_manager.get_queue(
 
</s> remove                     self.name, self._plugin_type, self.batchsize)
 </s> add                     self.name, self._plugin_type.title(), self.batchsize) </s> remove         tasks = ["extract_detect_in", "extract_align_in", "extract_mask_in", "extract_mask_out"]
 </s> add         tasks = ["extract_{}_in".format(phase) for phase in self._flow]
        tasks.append("extract_{}_out".format(self._final_phase)) </s> remove             retval = [None]
 </s> add             retval = [getattr(self, "_{}".format(self.phase))] </s> remove             if task == "extract_detect_in" or (not self._is_parallel
                                               and task == "extract_align_in"):
 </s> add             if task == "extract_{}_in".format(self._flow[0]) or (not self._is_parallel
                                                                 and not task.endswith("_out")): </s> remove         This method is overridable at the `<plugin_type>` level (ie.
 </s> add         This method should be overridden at the `<plugin_type>` level (IE.
            in_queue and out_queue should be previously created queue manager queues.
                      self.name, self._plugin_type, self.batchsize)
  
      def _add_queues(self, in_queue, out_queue, queues):
          """ Add the queues
            in_queue and out_queue should be previously created queue manager queues.
              queues should be a list of queue names """
          self._queues["in"] = in_queue
          self._queues["out"] = out_queue
          for q_name in queues:
              self._queues[q_name] = queue_manager.get_queue(
keep keep keep keep replace keep keep keep keep keep
 Smart Mask - Extract code review

- Lint simple_tests.py
- Only reformat alignments file if it exists otherwise change filename
- Update legacy alignments to new format at all stages
- faces_detect.Mask.from_dict - logging format fix
- convert.py fix otf for new pipeline
- cli.py - Add note that masks not used. Revert convert masks
- faces_detect.py - Revert non-extract code
- Add .p and .pickle extensions for serializer
- plugins/extract revert some changes
- scripts/fsmedia - Revert code changes
- Pipeline - cleanup
- Consistant alpha channel stripping (fixes single-process)
- Store landmarks as numpy array
- Code attribution
- Normalize feed face and reference face to 0.0 - 1.0 in convert
- Lock in mask VRAM sized
- Add documentation to plugin_loader
- Update alignments tool to work with new format 
plugins/extract/_base.py