Skip to content

Commit 946c041

Browse files
committed
Rename connection_metadata to client_routes
It was decided to rename table and events for better clarity.
1 parent 067a85c commit 946c041

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

cassandra/protocol.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -957,7 +957,7 @@ def send_body(self, f, protocol_version):
957957
'TOPOLOGY_CHANGE',
958958
'STATUS_CHANGE',
959959
'SCHEMA_CHANGE',
960-
'CONNECTION_METADATA_CHANGE'
960+
'CLIENT_ROUTES_CHANGE'
961961
))
962962

963963

@@ -989,7 +989,7 @@ def recv_body(cls, f, protocol_version, *args):
989989
raise NotSupportedError('Unknown event type %r' % event_type)
990990

991991
@classmethod
992-
def recv_connection_metadata_change(cls, f, protocol_version):
992+
def recv_client_routes_change(cls, f, protocol_version):
993993
# "UPDATE_NODES"
994994
change_type = read_string(f)
995995
connection_ids = read_stringlist(f)

tests/integration/standard/test_control_connection.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -132,9 +132,9 @@ def test_control_connection_port_discovery(self):
132132
assert 9042 == host.broadcast_rpc_port
133133
assert 7000 == host.broadcast_port
134134

135-
@xfail_scylla_version_lt(reason='scylladb/scylladb#26992 - system.connection_metadata is not yet supported',
135+
@xfail_scylla_version_lt(reason='scylladb/scylladb#26992 - system.client_routes is not yet supported',
136136
oss_scylla_version="7.0", ent_scylla_version="2025.4.0")
137-
def test_connection_metadata_change_event(self):
137+
def test_client_routes_change_event(self):
138138
cluster = TestCluster()
139139

140140
# Establish control connection
@@ -157,7 +157,7 @@ def on_event(event):
157157
finally:
158158
flag.set()
159159

160-
cluster.control_connection._connection.register_watchers({"CONNECTION_METADATA_CHANGE": on_event})
160+
cluster.control_connection._connection.register_watchers({"CLIENT_ROUTES_CHANGE": on_event})
161161

162162
try:
163163
payload = [
@@ -185,7 +185,7 @@ def on_event(event):
185185
}
186186
]
187187
response = requests.post(
188-
"http://" + cluster.contact_points[0] + ":10000/v2/connection-metadata",
188+
"http://" + cluster.contact_points[0] + ":10000/v2/client-routes",
189189
json=payload,
190190
headers={
191191
"Content-Type": "application/json",

0 commit comments

Comments
 (0)