def log_listener_process()

in azure/datalake/store/multiprocessor.py [0:0]

• 15 lines of code
• 6 McCabe index (conditional complexity)

def log_listener_process(queue):
    while True:
        try:
            record = queue.get(timeout=0.1)
            queue.task_done()
            if record == END_QUEUE_SENTINEL:  # We send this as a sentinel to tell the listener to quit.
                break
            logger = logging.getLogger("azure.datalake.store")
            #logger.handlers.clear()
            logger.handle(record)   # No level or filter logic applied - just do it!
        except Empty:               # Try again
            pass
        except Exception as e:
            import sys, traceback
            print('Problems in logging')
            traceback.print_exc(file=sys.stderr)