      def initialize(self, *args, **kwargs):
          """ Inititalize the detector
              Tasks to be run before any detection is performed.
              Override for specific detector """
          logger_init = kwargs["log_init"]
          log_queue = kwargs["log_queue"]
          logger_init(self.loglevel, log_queue)
          logger.debug("initialize %s (PID: %s, args: %s, kwargs: %s)",
                       self.__class__.__name__, os.getpid(), args, kwargs)
          self.init = kwargs.get("event", False)
          self.queues["in"] = kwargs["in_queue"]
          self.queues["out"] = kwargs["out_queue"]
 
</s> remove         logger_init = kwargs["log_init"]
        log_queue = kwargs["log_queue"]
        logger_init(self.loglevel, log_queue)
 </s> add  </s> remove         self.pool = ctx.Pool(processes=self.procs)

 </s> add         self.pool = ctx.Pool(processes=self.procs,
                             initializer=set_root_logger,
                             initargs=(logger.getEffectiveLevel(), LOG_QUEUE)) </s> remove         kwargs["log_init"] = set_root_logger
        kwargs["log_queue"] = LOG_QUEUE
 </s> add 
      def initialize(self, *args, **kwargs):
          """ Inititalize the detector
              Tasks to be run before any detection is performed.
              Override for specific detector """



          logger.debug("initialize %s (PID: %s, args: %s, kwargs: %s)",
                       self.__class__.__name__, os.getpid(), args, kwargs)
          self.init = kwargs.get("event", False)
          self.queues["in"] = kwargs["in_queue"]
          self.queues["out"] = kwargs["out_queue"]
keep keep keep keep replace replace replace keep keep keep keep keep
 Move mp logging functions to multithreading module 
plugins/extract/detect/_base.py