diff --git a/packages/cli/src/context/mcp/mongo-query-runner.ts b/packages/cli/src/context/mcp/mongo-query-runner.ts
index 65136cd8..2d45dc54 100644
--- a/packages/cli/src/context/mcp/mongo-query-runner.ts
+++ b/packages/cli/src/context/mcp/mongo-query-runner.ts
@@ -16,7 +16,7 @@ export async function runMongoQuery(
         `Connection "${connectionId}" driver "${connector.driver}" is not a MongoDB connection; mongo_query serves mongodb connections only.`,
       );
     }
-    return await connector.executeQuery({ ...input, connectionId }, { runId: 'mongo-query' });
+    return await connector.executeQuery(input, { runId: 'mongo-query' });
   } finally {
     await connector?.cleanup?.();
   }
diff --git a/packages/cli/src/mongo-query.ts b/packages/cli/src/mongo-query.ts
index 17b1e33e..bc0e6e8f 100644
--- a/packages/cli/src/mongo-query.ts
+++ b/packages/cli/src/mongo-query.ts
@@ -42,13 +42,7 @@ export async function runKtxMongoQuery(
     demoConnection = isDemoConnection(args.connectionId, connection);
 
     const createScanConnector = deps.createScanConnector ?? createKtxCliScanConnector;
-    const result = await runMongoQuery((connectionId) => createScanConnector(project!, connectionId), {
-      connectionId: args.connectionId,
-      collection: args.collection,
-      database: args.database,
-      pipeline: args.pipeline,
-      limit: args.limit,
-    });
+    const result = await runMongoQuery((connectionId) => createScanConnector(project!, connectionId), args);
 
     const output: KtxResultTable = {
       connectionId: args.connectionId,