          kwargs["in_queue"] = in_queue
          kwargs["out_queue"] = out_queue
          return kwargs
  
      def start(self):
          """ Add logging to start function """
          logger.debug("Spawning Process: (name: '%s', args: %s, kwargs: %s, daemon: %s)",
                       self._name, self._args, self._kwargs, self.daemon)
          super().start()
 
</s> remove         kwargs["log_init"] = set_root_logger
        kwargs["log_queue"] = LOG_QUEUE
 </s> add  </s> remove         logger_init = kwargs["log_init"]
        log_queue = kwargs["log_queue"]
        logger_init(self.loglevel, log_queue)
 </s> add  </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))
    def run(self):
        """ Add logger to spawned process """
        logger_init = self._kwargs["log_init"]
        log_queue = self._kwargs["log_queue"]
        log_level = self._kwargs["log_level"]
        logger_init(log_level, log_queue)
        super().run()

          kwargs["in_queue"] = in_queue
          kwargs["out_queue"] = out_queue
          return kwargs
  
    def run(self):
        """ Add logger to spawned process """
        logger_init = self._kwargs["log_init"]
        log_queue = self._kwargs["log_queue"]
        log_level = self._kwargs["log_level"]
        logger_init(log_level, log_queue)
        super().run()

      def start(self):
          """ Add logging to start function """
          logger.debug("Spawning Process: (name: '%s', args: %s, kwargs: %s, daemon: %s)",
                       self._name, self._args, self._kwargs, self.daemon)
          super().start()
keep keep keep add keep keep keep keep keep
 Move mp logging functions to multithreading module 
lib/multithreading.py