@@ -24,6 +24,7 @@ use std::sync::RwLock;
24
24
use ctor:: { ctor, dtor} ;
25
25
use iceberg:: io:: { S3_ACCESS_KEY_ID , S3_ENDPOINT , S3_REGION , S3_SECRET_ACCESS_KEY } ;
26
26
use iceberg:: spec:: { NestedField , PrimitiveType , Schema , Type } ;
27
+ use iceberg:: transaction:: { ApplyTransactionAction , Transaction } ;
27
28
use iceberg:: {
28
29
Catalog , CatalogBuilder , Namespace , NamespaceIdent , Result , TableCreation , TableIdent ,
29
30
} ;
@@ -36,7 +37,6 @@ use iceberg_test_utils::{normalize_test_name, set_up};
36
37
use port_scanner:: scan_port_addr;
37
38
use tokio:: time:: sleep;
38
39
use tracing:: info;
39
- use iceberg:: transaction:: { ApplyTransactionAction , Transaction } ;
40
40
41
41
const GLUE_CATALOG_PORT : u16 = 5000 ;
42
42
const MINIO_PORT : u16 = 9000 ;
@@ -432,7 +432,8 @@ async fn test_update_table() -> Result<()> {
432
432
433
433
// Update table properties using the transaction
434
434
let tx = Transaction :: new ( & table) ;
435
- let tx = tx. update_table_properties ( )
435
+ let tx = tx
436
+ . update_table_properties ( )
436
437
. set ( "test_property" . to_string ( ) , "test_value" . to_string ( ) )
437
438
. apply ( tx) ?;
438
439
@@ -451,10 +452,10 @@ async fn test_update_table() -> Result<()> {
451
452
original_metadata_location,
452
453
"Metadata location should be updated after commit"
453
454
) ;
454
-
455
+
455
456
// Load the table again from the catalog to verify changes were persisted
456
457
let reloaded_table = catalog. load_table ( table. identifier ( ) ) . await ?;
457
-
458
+
458
459
// Verify the reloaded table matches the updated table
459
460
assert_eq ! (
460
461
reloaded_table. metadata( ) . properties( ) . get( "test_property" ) ,
@@ -465,6 +466,6 @@ async fn test_update_table() -> Result<()> {
465
466
updated_table. metadata_location( ) ,
466
467
"Reloaded table should have the same metadata location as the updated table"
467
468
) ;
468
-
469
+
469
470
Ok ( ( ) )
470
471
}
0 commit comments