  
  import logging
  
  from lib.gpu_stats import GPUStats
  from lib.queue_manager import queue_manager, QueueEmpty
  from lib.utils import get_backend
  from plugins.plugin_loader import PluginLoader
 
</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, logger, ExtractMedia
import cv2

  
  import logging
  
import cv2

  from lib.gpu_stats import GPUStats
  from lib.queue_manager import queue_manager, QueueEmpty
  from lib.utils import get_backend
  from plugins.plugin_loader import PluginLoader
keep keep add keep keep keep keep
 plugins.extract - Create ExtractMedia class for pipeline flow
Bugfix - Fix memory leak in extract 
plugins/extract/pipeline.py