@@ -1174,8 +1174,8 @@ async fn test_set_domain_metadata_basic() -> Result<(), Box<dyn std::error::Erro
1174
1174
let domain2 = "spark.settings" ;
1175
1175
let config2 = r#"{"cores": 4}"# ;
1176
1176
1177
- txn. set_domain_metadata ( domain1. into ( ) , config1. into ( ) ) ?;
1178
- txn. set_domain_metadata ( domain2. into ( ) , config2. into ( ) ) ?;
1177
+ txn. set_domain_metadata ( domain1. to_string ( ) , config1. to_string ( ) ) ?;
1178
+ txn. set_domain_metadata ( domain2. to_string ( ) , config2. to_string ( ) ) ?;
1179
1179
txn. commit ( & engine) ?;
1180
1180
1181
1181
let commit_data = store
@@ -1227,15 +1227,13 @@ async fn test_set_domain_metadata_errors() -> Result<(), Box<dyn std::error::Err
1227
1227
let mut txn = snapshot. transaction ( ) ?;
1228
1228
1229
1229
// System domain rejection
1230
- assert ! ( txn
1231
- . set_domain_metadata( "delta.system" . into( ) , "config" . into( ) )
1232
- . is_err( ) ) ;
1230
+ let err = txn. set_domain_metadata ( "delta.system" . to_string ( ) , "config" . to_string ( ) ) . unwrap_err ( ) ;
1231
+ assert ! ( err. to_string( ) . contains( "system-controlled 'delta.*' domain" ) ) ;
1233
1232
1234
1233
// Duplicate domain rejection
1235
- txn. set_domain_metadata ( "app.config" . into ( ) , "v1" . into ( ) ) ?;
1236
- assert ! ( txn
1237
- . set_domain_metadata( "app.config" . into( ) , "v2" . into( ) )
1238
- . is_err( ) ) ;
1234
+ txn. set_domain_metadata ( "app.config" . to_string ( ) , "v1" . to_string ( ) ) ?;
1235
+ let err = txn. set_domain_metadata ( "app.config" . to_string ( ) , "v2" . to_string ( ) ) . unwrap_err ( ) ;
1236
+ assert ! ( err. to_string( ) . contains( "already specified in this transaction" ) ) ;
1239
1237
}
1240
1238
Ok ( ( ) )
1241
1239
}
0 commit comments