logstreams: Avoid crash on empty log messages

Signed-off-by: Michael Tremer <michael.tremer@ipfire.org>

diff --git a/src/buildservice/logstreams.py b/src/buildservice/logstreams.py
index 94be90f50ad8259989c5ac137663f7145032c540..35992fc2fe93470e0cff3df982d64d905967e992 100644 (file)
--- a/src/buildservice/logstreams.py
+++ b/src/buildservice/logstreams.py
@@ -122,6 +122,10 @@ class LogStream(base.Object):
                log.debug("%s has left the stream for %s" % (consumer, self.job))
 
        async def message(self, timestamp, level, message):
+               # Skip empty messages
+               if message is None:
+                       return
+
                # Translate the level
                try:
                        level = self.levels[level]