From: Michael Tremer <michael.tremer@ipfire.org>
Date: Tue, 25 Jul 2023 14:01:28 +0000 (+0000)
Subject: 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=1fa487c5455f3e4a63ae0755c466c2a7ee62b4e5;p=pbs.git

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

This will just queue tasks for all new messages and allows us to get
back to processing the next message quicker.

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

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