Skip to content
Browse files

WARN log (instead of exception) when we receive an unknown label

  • Loading branch information...
jesopo committed Jun 12, 2019
1 parent 568f6d7 commit 7324a05d3e12fffb4aaa00a8331651e5b9c85be0
Showing with 4 additions and 0 deletions.
  1. +4 −0 modules/
@@ -54,6 +54,10 @@ def batch_end(self, event):
self._recv(event["server"], label, event["batch"].get_lines())

def _recv(self, server, label, lines):
if not label in server._label_cache:
self.log.warn("unknown label received: %s", [label])

cached = server._label_cache.pop(label)"labeled-response").call(lines=lines)

0 comments on commit 7324a05

Please sign in to comment.
You can’t perform that action at this time.