Skip to content

Commit

Permalink
Revert "Add producer.close()"
Browse files Browse the repository at this point in the history
This reverts commit 139e078.

'Producer' object has no attribute 'close'
for confluent_kafka 2.4.0, the current version in
prompt-processing release.
  • Loading branch information
hsinfang committed Jul 17, 2024
1 parent cc69087 commit 83071da
Showing 1 changed file with 0 additions and 1 deletion.
1 change: 0 additions & 1 deletion python/lsst/ap/association/packageAlerts.py
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down

0 comments on commit 83071da

Please sign in to comment.