convert to test message

lsst-dm · Oct 1, 2024 · f46d0c4 · f46d0c4
1 parent 0731a95
commit f46d0c4
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main.py b/src/main.py
@@ -101,7 +101,8 @@ async def fan_out_msg(
     data
 ):
     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(json.dumps(data)))
+    await producer.send_and_wait(fan_out_topic, b"test")
 
 
 async def main() -> None: