diff --git a/query-engine/core/src/executor/interpreting_executor.rs b/query-engine/core/src/executor/interpreting_executor.rs index 868034e4c1c..9538a823601 100644 --- a/query-engine/core/src/executor/interpreting_executor.rs +++ b/query-engine/core/src/executor/interpreting_executor.rs @@ -1,6 +1,6 @@ use super::execute_operation::{execute_many_operations, execute_many_self_contained, execute_single_self_contained}; use super::request_context; -use crate::ITXManager; +use crate::ItxManager; use crate::{ protocol::EngineProtocol, BatchDocumentTransaction, CoreError, Operation, QueryExecutor, ResponseData, TransactionError, TransactionManager, TransactionOptions, TxId, @@ -18,7 +18,7 @@ pub struct InterpretingExecutor { /// The loaded connector connector: C, - itx_manager: ITXManager, + itx_manager: ItxManager, /// Flag that forces individual operations to run in a transaction. /// Does _not_ force batches to use transactions. @@ -33,7 +33,7 @@ where InterpretingExecutor { connector, force_transactions, - itx_manager: ITXManager::new(), + itx_manager: ItxManager::new(), } } } diff --git a/query-engine/core/src/interactive_transactions/manager.rs b/query-engine/core/src/interactive_transactions/manager.rs index 69be81dd5cb..6f925893305 100644 --- a/query-engine/core/src/interactive_transactions/manager.rs +++ b/query-engine/core/src/interactive_transactions/manager.rs @@ -20,7 +20,7 @@ pub static CLOSED_TX_CACHE_SIZE: Lazy = Lazy::new(|| match std::env::var( Err(_) => 100, }); -pub struct ITXManager { +pub struct ItxManager { /// Stores all current transactions (some of them might be already committed/expired/rolled back). /// /// There are two tiers of locks here: @@ -49,7 +49,7 @@ pub struct ITXManager { timeout_sender: UnboundedSender, } -impl ITXManager { +impl ItxManager { pub fn new() -> Self { let transactions: Arc>>>> = Arc::new(RwLock::new(HashMap::default())); @@ -59,7 +59,7 @@ impl ITXManager { // This task rollbacks and removes any open transactions with expired timeouts from the // `self.transactions`. It also removes any closed transactions to avoid `self.transactions` // growing infinitely in size over time. - // Note that this task automatically exits when all transactions finish and the `ITXManager` + // Note that this task automatically exits when all transactions finish and the `ItxManager` // is dropped, because that causes the `timeout_receiver` to become closed. crosstarget_utils::task::spawn({ let transactions = transactions.clone();