          >>>     if extractor.final_pass:
          >>>         <do final processing>
          >>>     else:
          >>>         <do intermediate processing>
          >>>         extractor.input_queue.put({"filename": "path/to/image/file",
          >>>                                    "image": numpy.array(image),
          >>>                                    "detected_faces": [<DetectedFace objects]})
          """
          retval = self._is_parallel or self.phase == self._final_phase
          logger.trace(retval)
          return retval
  
 
</s> remove         >>>         extractor.input_queue.put({"filename": "path/to/image/file",
        >>>                                    "image": numpy.array(image),
        >>>                                    "detected_faces": [<DetectedFace objects]})
 </s> add         >>>         extract_media.set_image(image)
        >>>         extractor.input_queue.put(extract_media) </s> remove         >>>         extractor.input_queue.put({"filename": "path/to/image/file",
        >>>                                    "image": numpy.array(image)})
 </s> add         >>>         extract_media = ExtractMedia("path/to/image/file", image)
        >>>         extractor.input_queue.put(extract_media) </s> remove >>>  "image": [<source image>],
 </s> add  </s> remove >>>  "image": <four channel source image>,
 </s> add 
        >>>         extractor.input_queue.put(extract_media)
          >>>     if extractor.final_pass:
          >>>         <do final processing>
          >>>     else:
          >>>         <do intermediate processing>
        >>>         extractor.input_queue.put(extract_media)
        >>>         extractor.input_queue.put(extract_media)
        >>>         extractor.input_queue.put(extract_media)
          """
          retval = self._is_parallel or self.phase == self._final_phase
          logger.trace(retval)
          return retval
  
keep keep keep keep replace replace replace keep keep keep keep keep
 plugins.extract - Create ExtractMedia class for pipeline flow
Bugfix - Fix memory leak in extract 
plugins/extract/pipeline.py