def _process_queue()

in zktraffic/stats/loaders.py [0:0]

• 13 lines of code
• 5 McCabe index (conditional complexity)

  def _process_queue(self, queue, handlers):
    while True:
      try:
        item = queue.pop()
      except IndexError:
        break

      try:
        _ = [handler(item) for handler in handlers]
      except Exception as ex:
        name = getattr(item, "name", "")
        path = getattr(item, "path", "")
        ip = getattr(item, "ip", "")
        log.error("Handler call for item %s, %s, %s failed: %s", name, path, ip, ex)