File tree Expand file tree Collapse file tree
crates/datastore/src/locking_tx_datastore Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -590,7 +590,7 @@ impl<'cs> ReplayCommittedState<'cs> {
590590 let target_col_id = ColId :: deserialize ( ValueDeserializer :: from_ref ( & st_column_row. elements [ 1 ] ) )
591591 . expect ( "second field in `st_column` should decode to a `ColId`" ) ;
592592
593- let outdated_st_column_rows = iter_st_column_for_table ( self . state , & target_table_id. into ( ) ) ?
593+ let outdated_st_column_rows = iter_st_column_for_table ( self , & target_table_id. into ( ) ) ?
594594 . filter_map ( |row_ref| {
595595 StColumnRow :: try_from ( row_ref)
596596 . map ( |c| ( c. col_pos == target_col_id && row_ref. pointer ( ) != row_ptr) . then ( || row_ref. pointer ( ) ) )
@@ -620,7 +620,7 @@ impl<'cs> ReplayCommittedState<'cs> {
620620 // and not the other one, as it is being replaced.
621621 // `Self::ignore_previous_version_of_column` has marked the old version as ignored,
622622 // so filter only the non-ignored columns.
623- let mut columns = iter_st_column_for_table ( self . state , & table_id. into ( ) ) ?
623+ let mut columns = iter_st_column_for_table ( self , & table_id. into ( ) ) ?
624624 . filter ( |row_ref| !self . replay_columns_to_ignore . contains ( & row_ref. pointer ( ) ) )
625625 . map ( |row_ref| {
626626 let row = StColumnRow :: try_from ( row_ref) ?;
You can’t perform that action at this time.
0 commit comments