diff --git a/cassandra/protocol.py b/cassandra/protocol.py index 8fee0db101..e574965de8 100644 --- a/cassandra/protocol.py +++ b/cassandra/protocol.py @@ -957,7 +957,7 @@ def send_body(self, f, protocol_version): 'TOPOLOGY_CHANGE', 'STATUS_CHANGE', 'SCHEMA_CHANGE', - 'CONNECTION_METADATA_CHANGE' + 'CLIENT_ROUTES_CHANGE' )) @@ -989,7 +989,7 @@ def recv_body(cls, f, protocol_version, *args): raise NotSupportedError('Unknown event type %r' % event_type) @classmethod - def recv_connection_metadata_change(cls, f, protocol_version): + def recv_client_routes_change(cls, f, protocol_version): # "UPDATE_NODES" change_type = read_string(f) connection_ids = read_stringlist(f) diff --git a/tests/integration/standard/test_control_connection.py b/tests/integration/standard/test_control_connection.py index 350c6a5ffe..206945f0b3 100644 --- a/tests/integration/standard/test_control_connection.py +++ b/tests/integration/standard/test_control_connection.py @@ -132,9 +132,9 @@ def test_control_connection_port_discovery(self): assert 9042 == host.broadcast_rpc_port assert 7000 == host.broadcast_port - @xfail_scylla_version_lt(reason='scylladb/scylladb#26992 - system.connection_metadata is not yet supported', + @xfail_scylla_version_lt(reason='scylladb/scylladb#26992 - system.client_routes is not yet supported', oss_scylla_version="7.0", ent_scylla_version="2025.4.0") - def test_connection_metadata_change_event(self): + def test_client_routes_change_event(self): cluster = TestCluster() # Establish control connection @@ -157,7 +157,7 @@ def on_event(event): finally: flag.set() - cluster.control_connection._connection.register_watchers({"CONNECTION_METADATA_CHANGE": on_event}) + cluster.control_connection._connection.register_watchers({"CLIENT_ROUTES_CHANGE": on_event}) try: payload = [ @@ -185,7 +185,7 @@ def on_event(event): } ] response = requests.post( - "http://" + cluster.contact_points[0] + ":10000/v2/connection-metadata", + "http://" + cluster.contact_points[0] + ":10000/v2/client-routes", json=payload, headers={ "Content-Type": "application/json",