From c59d54c427a1741d431483256a6bf1d12c612e6c Mon Sep 17 00:00:00 2001
From: "wu.chunyang" <wuchunyang@yovole.com>
Date: Wed, 27 Mar 2024 22:57:32 +0800
Subject: [PATCH] db: add commit action after querying

Change-Id: Ibe39a9b999680cc1fba4eccd9fa2ed0fa41ccb00
---
 trove/db/sqlalchemy/api.py | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/trove/db/sqlalchemy/api.py b/trove/db/sqlalchemy/api.py
index 38b22e4057..4bafdfbb8d 100644
--- a/trove/db/sqlalchemy/api.py
+++ b/trove/db/sqlalchemy/api.py
@@ -54,8 +54,11 @@ def find_all(model, **conditions):
 
 def find_all_by_limit(query_func, model, conditions, limit, marker=None,
                       marker_column=None):
-    return _limits(query_func, model, conditions, limit, marker,
-                   marker_column).all()
+    query = _limits(query_func, model, conditions, limit, marker,
+                    marker_column)
+    res = query.all()
+    query.session.commit()
+    return res
 
 
 def find_by(model, **kwargs):