  from lib.queue_manager import queue_manager
  from lib.utils import GetModel, FaceswapError
  from ._config import Config
  
  logger = logging.getLogger(__name__)  # pylint: disable=invalid-name
  
  # TODO CPU mode
  # TODO Run with warnings mode
  
 
</s> remove import cv2
import numpy as np

 </s> add  </s> remove from plugins.extract.pipeline import Extractor
 </s> add from plugins.extract.pipeline import Extractor, ExtractMedia </s> remove         # from lib.queue_manager import queue_manager
        # queue_manager.debug_monitor(3)
 </s> add         # from lib.queue_manager import queue_manager ; queue_manager.debug_monitor(3) </s> remove from plugins.extract._base import Extractor, logger
 </s> add from plugins.extract._base import Extractor, ExtractMedia, logger
from .pipeline import ExtractMedia
  from lib.queue_manager import queue_manager
  from lib.utils import GetModel, FaceswapError
  from ._config import Config
from .pipeline import ExtractMedia
  
  logger = logging.getLogger(__name__)  # pylint: disable=invalid-name
  
  # TODO CPU mode
  # TODO Run with warnings mode
  
keep keep add keep keep keep keep keep keep
 plugins.extract - Create ExtractMedia class for pipeline flow
Bugfix - Fix memory leak in extract 
plugins/extract/_base.py