Skip to content

Commit

Permalink
fix: Ensure proper shutdown of the cluster in CassandraOnlineStore
Browse files Browse the repository at this point in the history
  • Loading branch information
Bhargav Dodla committed Jan 10, 2025
1 parent b7541b2 commit 267f72b
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -395,6 +395,7 @@ def online_write_batch(
print(f"Error writing a batch: {exc}")
raise Exception("Error writing a batch") from exc
session.shutdown()
self._cluster.shutdown()
# correction for the last missing call to `progress`:
if progress:
progress(1)
Expand Down

0 comments on commit 267f72b

Please sign in to comment.