Merge pull request #226 from lsst/tickets/DM-45023

DM-45023: Add close to producer
lsst · Jul 2, 2024 · cc69087 · cc69087
2 parents 0491626 + 139e078
commit cc69087
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/python/lsst/ap/association/packageAlerts.py b/python/lsst/ap/association/packageAlerts.py
@@ -306,6 +306,7 @@ def run(self,
 
         if self.config.doProduceAlerts:
             self.produceAlerts(alerts, visit, detector)
+            self.producer.close()
 
         if self.config.doWriteAlerts:
             with open(os.path.join(self.config.alertWriteLocation, f"{visit}_{detector}.avro"), "wb") as f: