minor

Author: CTTY

crates/iceberg/src/transaction/action/mod.rs

@@ -21,7 +21,8 @@ use crate::{Result, TableUpdate};
 pub type PendingAction = Box<dyn TransactionAction>;
 
 pub(crate) trait TransactionAction: Sync {
-    /// Commit the changes and apply the changes to the transaction, return the updated transaction
+    /// Commit the changes and apply the changes to the transaction,
+    /// return the transaction with the updated current_table
     fn commit(self, tx: Transaction) -> Result<Transaction>;
 }
 

crates/iceberg/src/transaction/mod.rs

@@ -33,7 +33,7 @@ use crate::TableUpdate::UpgradeFormatVersion;
 use crate::error::Result;
 use crate::spec::FormatVersion;
 use crate::table::Table;
-use crate::transaction::action::{SetLocation, TransactionAction, PendingAction};
+use crate::transaction::action::{PendingAction, SetLocation, TransactionAction};
 use crate::transaction::append::FastAppendAction;
 use crate::transaction::sort_order::ReplaceSortOrderAction;
 use crate::{Catalog, Error, ErrorKind, TableCommit, TableRequirement, TableUpdate};
@@ -64,7 +64,7 @@ impl<'a> Transaction<'a> {
         for action in &old_tx.actions {
             new_tx = action.commit(new_tx)?
         }
-        
+
         Ok(new_tx)
     }
 
@@ -223,7 +223,7 @@ impl<'a> Transaction<'a> {
         {
             // refresh table
             let new_tx = Transaction::refresh(self, refreshed)?;
-            return new_tx.commit(catalog).await
+            return new_tx.commit(catalog).await;
             // TODO instead of refreshing directly, retry on this error
             // return Err(Error::new(
             //     ErrorKind::DataInvalid,