logstreams: Correctly destroy the stream

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

diff --git a/src/buildservice/logstreams.py b/src/buildservice/logstreams.py
index 35992fc2fe93470e0cff3df982d64d905967e992..b8be6cd997e95038a82f4f4f5f0acf5952e1eee1 100644 (file)
--- a/src/buildservice/logstreams.py
+++ b/src/buildservice/logstreams.py
@@ -47,8 +47,8 @@ class LogStreams(base.Object):
                        Closes the stream for a job
                """
                try:
-                       self.streams.remove(job)
-               except ValueError:
+                       del self.streams[job]
+               except KeyError:
                        return
 
        async def join(self, job, consumer):