Skip to content

Commit

Permalink
fix: Disable shard awareness in Cassandra cluster configuration
Browse files Browse the repository at this point in the history
  • Loading branch information
Bhargav Dodla committed Jan 10, 2025
1 parent 267f72b commit 3580383
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -301,6 +301,7 @@ def _get_session(self, config: RepoConfig):
self._cluster = Cluster(
cloud={"secure_connect_bundle": secure_bundle_path},
auth_provider=auth_provider,
shard_aware_options=dict(disable=True),
**cluster_kwargs,
)

Expand Down Expand Up @@ -394,8 +395,6 @@ def online_write_batch(
logger.error(f"Error writing a batch: {exc}")
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 3580383

Please sign in to comment.