Skip to content

Commit

Permalink
remote/exporter: flush messages regularly during exporter startup
Browse files Browse the repository at this point in the history
Signed-off-by: Jan Luebbe <[email protected]>
  • Loading branch information
jluebbe committed Jun 14, 2024
1 parent 71f1fed commit a0d098c
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions labgrid/remote/exporter.py
Original file line number Diff line number Diff line change
Expand Up @@ -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())

Expand Down

0 comments on commit a0d098c

Please sign in to comment.