moved producer

lsst-dm · Sep 30, 2024 · 98939c2 · 98939c2
1 parent aa70512
commit 98939c2
Showing 1 changed file with 6 additions and 7 deletions.
diff --git a/src/main.py b/src/main.py
@@ -206,13 +206,6 @@ async def main() -> None:
 
     tasks = set()
 
-    # https://aiokafka.readthedocs.io/en/stable/producer.html
-    producer = AIOKafkaProducer(
-        bootstrap_servers=prompt_processing_kafka_cluster
-    )
-    await producer.start()
-    logging.info ("started kafka producer")
-
     async with httpx.AsyncClient() as client:
 
         try:
@@ -370,6 +363,12 @@ async def main() -> None:
                             )
 
                     try:
+                        # https://aiokafka.readthedocs.io/en/stable/producer.html
+                        producer = AIOKafkaProducer(
+                            bootstrap_servers=prompt_processing_kafka_cluster
+                        )
+                        await producer.start()
+                        logging.info ("started kafka producer")
 
                         #for fan_out_message in fan_out_message_list: