Remove test message and close producer in the fan_out_msg function.

lsst-dm · Oct 1, 2024 · eca3cfc · eca3cfc
1 parent d2e513a
commit eca3cfc
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/src/main.py b/src/main.py
@@ -102,8 +102,8 @@ async def fan_out_msg(
 ):
     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")
+    await producer.send_and_wait(fan_out_topic, b(json.dumps(data)))
+    await producer.stop()
 
 
 async def main() -> None:
@@ -393,7 +393,6 @@ async def main() -> None:
 
         finally:
             await consumer.stop()
-            await producer.stop()
 
 
 asyncio.run(main())