Set stream name.

lsst-dm · Dec 23, 2024 · 428dfbf · 428dfbf
1 parent 2965b15
commit 428dfbf
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/main.py b/src/main.py
@@ -101,11 +101,10 @@ def detector_load(conf: dict, instrument: str) -> list[int]:
 
 async def fan_out_msg(
     redis_client,
-    fan_out_topic,
     data
 ):
     logging.info(f"sending msg {data}")
-    await redis_client.xadd(fan_out_topic, data)
+    await redis_client.xadd("instrument:lsstcomcamsim", data)
 
 async def main() -> None:
 
@@ -433,7 +432,6 @@ async def main() -> None:
 
                                 fan_out_msg(
                                     redis_client,
-                                    fan_out_topic,
                                     fan_out_message
                                 )
                             )