From: Michael Tremer <michael.tremer@ipfire.org>
Date: Tue, 25 Jul 2023 14:12:18 +0000 (+0000)
Subject: Revert "logstreams: Don't wait until all messages have been delivered to all consumers"
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=0fd02e6db1517902ff7026191409abf14dec9586;p=pbs.git

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 e5b37b80..8769fd2b 100644
--- 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),
+					)