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):