We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents d735957 + 83d7394 commit d12d2c1Copy full SHA for d12d2c1
cassandra/cluster.py
@@ -3668,6 +3668,11 @@ def _try_connect(self, host):
3668
"registering watchers and refreshing schema and topology",
3669
connection)
3670
3671
+ # Indirect way to determine if conencted to a ScyllaDB cluster, which does not support peers_v2
3672
+ # If sharding information is available, it's a ScyllaDB cluster, so do not use peers_v2 table.
3673
+ if connection.features.sharding_info is not None:
3674
+ self._uses_peers_v2 = False
3675
+
3676
# use weak references in both directions
3677
# _clear_watcher will be called when this ControlConnection is about to be finalized
3678
# _watch_callback will get the actual callback from the Connection and relay it to
0 commit comments