update parameters to pass in kafka producer

lsst-dm · Aug 27, 2024 · 914996f · 914996f
1 parent 5a43c57
commit 914996f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main.py b/src/main.py
@@ -437,6 +437,7 @@ async def main() -> None:
 
                             task = asyncio.create_task(
                                 fan_out_msg(
+                                    producer,
                                     fan_out_topic,
                                     fan_out_message
                                 )