diff --git a/tests/table/table_test.py b/tests/table/table_test.py
index 97bdcc88..183f3ed4 100644
--- a/tests/table/table_test.py
+++ b/tests/table/table_test.py
@@ -27,3 +27,13 @@ def create_table(session: ydb.Session):
 
         res = driver_sync.scheme_client.describe_path(table_path)
         assert res.type == ydb.scheme.SchemeEntryType.TABLE
+
+    def test_select_text_query_with_params(self, driver_sync):
+        def select(session: ydb.Session):
+            text_query = "DECLARE $v AS Int64; SELECT $v"
+            session.prepare(text_query)
+            with session.transaction() as tx:
+                tx.execute(text_query, {"$v": 1})
+
+        pool = ydb.SessionPool(driver=driver_sync)
+        pool.retry_operation_sync(select)
diff --git a/ydb/_tx_ctx_impl.py b/ydb/_tx_ctx_impl.py
index 04877bb2..969a4dc4 100644
--- a/ydb/_tx_ctx_impl.py
+++ b/ydb/_tx_ctx_impl.py
@@ -159,7 +159,5 @@ def wrap_result_and_tx_id(rpc_state, response_pb, session_state, tx_state, query
     issues._process_response(response_pb.operation)
     message = _apis.ydb_table.ExecuteQueryResult()
     response_pb.operation.result.Unpack(message)
-    if message.query_meta.id:
-        session_state.keep(query, message.query_meta.id)
     tx_state.tx_id = None if not message.tx_meta.id else message.tx_meta.id
     return convert.ResultSets(message.result_sets, session_state.table_client_settings)