From a0d098c6a85637a1fdfec798f5ff0795cd4b1383 Mon Sep 17 00:00:00 2001 From: Jan Luebbe Date: Fri, 14 Jun 2024 14:19:35 +0200 Subject: [PATCH] remote/exporter: flush messages regularly during exporter startup Signed-off-by: Jan Luebbe --- labgrid/remote/exporter.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/labgrid/remote/exporter.py b/labgrid/remote/exporter.py index 8ecd7f91f..7365112b9 100755 --- a/labgrid/remote/exporter.py +++ b/labgrid/remote/exporter.py @@ -777,6 +777,9 @@ async def run(self) -> None: group_name, resource_name, cls, params ) + # flush queued message + await self.out_queue.join() + logging.info("creating poll task") self.poll_task = self.loop.create_task(self.poll())