add producer flush

lsst-dm · Oct 29, 2024 · fa58f9b · fa58f9b
1 parent bcd27ff
commit fa58f9b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main.py b/src/main.py
@@ -103,6 +103,7 @@ async def fan_out_msg(
     await producer.start()
     logging.info(f"sending msg {data}")
     await producer.send_and_wait(fan_out_topic, data)
+    await producer.flush()
     await producer.stop()