Skip to content

Commit db5df52

Browse files
committed
pool: log error when failed to connect to shard
Added an error log when driver fails to connect to specific shard.
1 parent 8138dca commit db5df52

File tree

1 file changed

+8
-5
lines changed

1 file changed

+8
-5
lines changed

Diff for: cassandra/pool.py

+8-5
Original file line numberDiff line numberDiff line change
@@ -719,12 +719,15 @@ def _open_connection_to_missing_shard(self, shard_id):
719719
return
720720
shard_aware_endpoint = self._get_shard_aware_endpoint()
721721
log.debug("shard_aware_endpoint=%r", shard_aware_endpoint)
722-
723722
if shard_aware_endpoint:
724-
conn = self._session.cluster.connection_factory(shard_aware_endpoint, host_conn=self, on_orphaned_stream_released=self.on_orphaned_stream_released,
725-
shard_id=shard_id,
726-
total_shards=self.host.sharding_info.shards_count)
727-
conn.original_endpoint = self.host.endpoint
723+
try:
724+
conn = self._session.cluster.connection_factory(shard_aware_endpoint, host_conn=self, on_orphaned_stream_released=self.on_orphaned_stream_released,
725+
shard_id=shard_id,
726+
total_shards=self.host.sharding_info.shards_count)
727+
conn.original_endpoint = self.host.endpoint
728+
except Exception as exc:
729+
log.error("Failed to open connection to %s, on shard_id=%i: %s", self.host, shard_id, exc)
730+
raise exc
728731
else:
729732
conn = self._session.cluster.connection_factory(self.host.endpoint, host_conn=self, on_orphaned_stream_released=self.on_orphaned_stream_released)
730733

0 commit comments

Comments
 (0)