@@ -110,24 +110,30 @@ impl ClusterState {
110110 }
111111
112112 let keyspaces: HashMap < String , Keyspace > = metadata
113- . keyspaces
114- . into_iter ( )
115- . filter_map ( |( ks_name, ks) | match ks {
116- Ok ( ks) => Some ( ( ks_name, ks) ) ,
117- Err ( e) => {
118- if let Some ( old_ks) = old_keyspaces. get ( & ks_name) {
119- warn ! ( "Encountered an error while processing metadata of keyspace \" {ks_name}\" : {e}.\
120- Re-using older version of this keyspace metadata") ;
121- Some ( ( ks_name, old_ks. clone ( ) ) )
122- } else {
123- warn ! ( "Encountered an error while processing metadata of keyspace \" {ks_name}\" : {e}.\
124- No previous version of this keyspace metadata found, so it will not be\
125- present in ClusterData until next refresh.") ;
126- None
113+ . keyspaces
114+ . into_iter ( )
115+ . filter_map ( |( ks_name, ks) | match ks {
116+ Ok ( ks) => Some ( ( ks_name, ks) ) ,
117+ Err ( e) => {
118+ if let Some ( old_ks) = old_keyspaces. get ( & ks_name) {
119+ warn ! (
120+ "Encountered an error while processing\
121+ metadata of keyspace \" {ks_name}\" : {e}.\
122+ Re-using older version of this keyspace metadata"
123+ ) ;
124+ Some ( ( ks_name, old_ks. clone ( ) ) )
125+ } else {
126+ warn ! (
127+ "Encountered an error while processing metadata\
128+ of keyspace \" {ks_name}\" : {e}.\
129+ No previous version of this keyspace metadata found, so it will not be\
130+ present in ClusterData until next refresh."
131+ ) ;
132+ None
133+ }
127134 }
128- }
129- } )
130- . collect ( ) ;
135+ } )
136+ . collect ( ) ;
131137
132138 {
133139 let removed_nodes = {
0 commit comments