From 139e078ecc6604e0083bf0b5f4c96cd8a0050754 Mon Sep 17 00:00:00 2001 From: Brianna Smart Date: Mon, 1 Jul 2024 11:38:30 -0700 Subject: [PATCH] Add producer.close() --- python/lsst/ap/association/packageAlerts.py | 1 + 1 file changed, 1 insertion(+) diff --git a/python/lsst/ap/association/packageAlerts.py b/python/lsst/ap/association/packageAlerts.py index b282c8f1..1b49a5bb 100644 --- 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: