Repository: incubator-ariatosca Updated Branches: refs/heads/ARIA-213-Sporadic-tests-failures-over-locked-database-issue cda826403 -> 0433e828c (forced update)
isolation level fix Project: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/commit/0433e828 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/tree/0433e828 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/diff/0433e828 Branch: refs/heads/ARIA-213-Sporadic-tests-failures-over-locked-database-issue Commit: 0433e828cd643b1504525a122f58af62982359d3 Parents: fedfb0d Author: max-orlov <ma...@gigaspaces.com> Authored: Wed Jun 7 11:49:03 2017 +0300 Committer: max-orlov <ma...@gigaspaces.com> Committed: Wed Jun 7 12:53:45 2017 +0300 ---------------------------------------------------------------------- aria/storage/sql_mapi.py | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/blob/0433e828/aria/storage/sql_mapi.py ---------------------------------------------------------------------- diff --git a/aria/storage/sql_mapi.py b/aria/storage/sql_mapi.py index 68d0ff6..657d769 100644 --- a/aria/storage/sql_mapi.py +++ b/aria/storage/sql_mapi.py @@ -21,6 +21,7 @@ import platform from sqlalchemy import ( create_engine, orm, + event ) from sqlalchemy.exc import SQLAlchemyError from sqlalchemy.orm.exc import StaleDataError @@ -405,13 +406,19 @@ def init_storage(base_dir, filename='db.sqlite'): path=os.path.join(base_dir, filename)) - engine = create_engine(uri, connect_args=dict(timeout=15)) + engine = create_engine(uri) + event.listen(engine, 'connect', do_connect) + session_factory = orm.sessionmaker(bind=engine) session = orm.scoped_session(session_factory=session_factory) return dict(engine=engine, session=session) +def do_connect(dbapi_connection, _): + dbapi_connection.isolation_level = None + + class ListResult(list): """ a ListResult contains results about the requested items.