Decode strip logline during the handling of log streams
@@ -14,7 +14,7 @@ def _handle_log_stream(stream, publish):
log_lines = []
last_emit_time = time.time()
for log_line in stream:
- log_lines.append(log_line)
+ log_lines.append(log_line.decode('utf-8').strip())
publish_cond = (
len(log_lines) == publisher.MESSAGES_COUNT or
(log_lines and time.time() - last_emit_time > publisher.MESSAGES_TIMEOUT)
