Revert "logstreams: Don't wait until all messages have been delivered to all consumers"

This reverts commit 1fa487c5455f3e4a63ae0755c466c2a7ee62b4e5.

This might potentially shuffle the messages :(

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

diff --git a/src/buildservice/logstreams.py b/src/buildservice/logstreams.py
index e5b37b80d8eb398c44de1c05d1395ef4a3e94887..8769fd2b017d19deade83795163abaaddd40f851 100644 (file)
--- a/src/buildservice/logstreams.py
+++ b/src/buildservice/logstreams.py
@@ -154,5 +154,8 @@ class LogStream(base.Object):
                        self.buffer.append(m)
 
                        # Send the message to all consumers
-                       for c in self.consumers:
-                               self.backend.run_task(c.message, m)
+                       async with asyncio.TaskGroup() as tasks:
+                               for c in self.consumers:
+                                       tasks.create_task(
+                                               c.message(m),
+                                       )