Merge pull request #228 from lsst/tickets/DM-45299

DM-45299: Revert DM-45023
lsst · Jul 17, 2024 · 2c5e806 · 2c5e806
2 parents cc69087 + 83071da
commit 2c5e806
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/python/lsst/ap/association/packageAlerts.py b/python/lsst/ap/association/packageAlerts.py
@@ -306,7 +306,6 @@ 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: