@@ -746,6 +746,9 @@ impl ControlConnection {
746
746
#[ scylla( crate = "scylla_cql" ) ]
747
747
struct NodeInfoRow {
748
748
host_id : Option < Uuid > ,
749
+ #[ allow( dead_code) ] // TODO: remove later
750
+ #[ scylla( rename = "release_version" ) ]
751
+ server_version : Option < String > ,
749
752
#[ scylla( rename = "rpc_address" ) ]
750
753
untranslated_ip_addr : IpAddr ,
751
754
#[ scylla( rename = "data_center" ) ]
@@ -774,7 +777,7 @@ const METADATA_QUERY_PAGE_SIZE: i32 = 1024;
774
777
impl ControlConnection {
775
778
async fn query_peers ( & self , connect_port : u16 ) -> Result < Vec < Peer > , MetadataError > {
776
779
let mut peers_query = Statement :: new (
777
- "select host_id, rpc_address, data_center, rack, tokens from system.peers" ,
780
+ "select host_id, release_version, rpc_address, data_center, rack, tokens from system.peers" ,
778
781
) ;
779
782
peers_query. set_page_size ( METADATA_QUERY_PAGE_SIZE ) ;
780
783
let peers_query_stream = self
@@ -795,7 +798,7 @@ impl ControlConnection {
795
798
. and_then ( |row_result| future:: ok ( ( NodeInfoSource :: Peer , row_result) ) ) ;
796
799
797
800
let mut local_query =
798
- Statement :: new ( "select host_id, rpc_address, data_center, rack, tokens from system.local WHERE key='local'" ) ;
801
+ Statement :: new ( "select host_id, release_version, rpc_address, data_center, rack, tokens from system.local WHERE key='local'" ) ;
799
802
local_query. set_page_size ( METADATA_QUERY_PAGE_SIZE ) ;
800
803
let local_query_stream = self
801
804
. query_iter ( local_query)
@@ -847,6 +850,7 @@ impl ControlConnection {
847
850
) -> Option < Peer > {
848
851
let NodeInfoRow {
849
852
host_id,
853
+ server_version : _,
850
854
untranslated_ip_addr,
851
855
datacenter,
852
856
rack,
0 commit comments