          Example
          -------
          >>> for phase in extractor.passes:
          >>>     if phase == 1:
          >>>         extractor.input_queue.put({"filename": "path/to/image/file",
          >>>                                    "image": numpy.array(image)})
          >>>     else:
          >>>         extractor.input_queue.put({"filename": "path/to/image/file",
          >>>                                    "image": numpy.array(image),
          >>>                                    "detected_faces": [<DetectedFace objects]})
          """
 
</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),
        >>>                                    "detected_faces": [<DetectedFace objects]})
 </s> add         >>>         extractor.input_queue.put(extract_media) </s> remove         >>> for face in extractor.detected_faces():
        >>>     filename = face["filename"]
        >>>     image = face["image"]
        >>>     detected_faces = face["detected_faces"]
 </s> add         >>> for extract_media in extractor.detected_faces():
        >>>     filename = extract_media.filename
        >>>     image = extract_media.image
        >>>     detected_faces = extract_media.detected_faces </s> remove >>>  "image": [<source image>],
 </s> add  </s> remove The plugin will receive a dict containing:

>>> {"filename": [<filename of source frame>],
>>>  "image": [<source image>],
>>>  "detected_faces": [<list of DetectedFace objects]}
 </s> add The plugin will receive a :class:`~plugins.extract.pipeline.ExtractMedia` object.
        >>>         extract_media = ExtractMedia("path/to/image/file", image)
        >>>         extractor.input_queue.put(extract_media)
          Example
          -------
          >>> for phase in extractor.passes:
          >>>     if phase == 1:
        >>>         extract_media = ExtractMedia("path/to/image/file", image)
        >>>         extractor.input_queue.put(extract_media)
        >>>         extract_media = ExtractMedia("path/to/image/file", image)
        >>>         extractor.input_queue.put(extract_media)
          >>>     else:
          >>>         extractor.input_queue.put({"filename": "path/to/image/file",
          >>>                                    "image": numpy.array(image),
          >>>                                    "detected_faces": [<DetectedFace objects]})
          """
keep keep keep keep 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