code: def log_queue():
      """
      Get the log queue for child process logging.
      """
      global _log_queue, _log_listener
      from lenskit.util.parallel import LKContext
  
      ctx = LKContext.INSTANCE
      if _log_queue is None:
          _log_queue = ctx.Queue()
          _log_listener = QueueListener(_log_queue, InjectHandler())
          _log_listener.start()
      return _log_queue
  
file_path: lkpy/lenskit/util/log.py
imports: import sys
  import logging
  from logging.handlers import QueueListener
  import multiprocessing
label_desc: Use image node_id 3 for calling a global function with example usage: log_queue() and returns: _log_queue