diff --git a/query-engine/query-engine/src/server/mod.rs b/query-engine/query-engine/src/server/mod.rs
index 32203f6fd760..d370b8c7432d 100644
--- a/query-engine/query-engine/src/server/mod.rs
+++ b/query-engine/query-engine/src/server/mod.rs
@@ -335,7 +335,7 @@ async fn transaction_commit_handler(
         capturer.start_capturing().await;
     }
 
-    let result = state.cx.executor.rollback_tx(tx_id).await;
+    let result = state.cx.executor.commit_tx(tx_id).await;
 
     let telemetry = if let telemetry::capturing::Capturer::Enabled(capturer) = capture_config {
         capturer.fetch_captures().await