await producer start

lsst-dm · Oct 1, 2024 · d2e513a · d2e513a
1 parent f46d0c4
commit d2e513a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main.py b/src/main.py
@@ -100,6 +100,7 @@ async def fan_out_msg(
     fan_out_topic,
     data
 ):
+    await producer.start()
     logging.info(f"sending msg {data}")
     #await producer.send_and_wait(fan_out_topic, b(json.dumps(data)))
     await producer.send_and_wait(fan_out_topic, b"test")