Update _session to session
This commit is contained in:
		| @@ -20,7 +20,7 @@ def start_convert_db(args: Dict[str, Any]) -> None: | ||||
|     config = setup_utils_configuration(args, RunMode.UTIL_NO_EXCHANGE) | ||||
|  | ||||
|     init_db(config['db_url']) | ||||
|     session_target = Trade._session | ||||
|     session_target = Trade.session | ||||
|     init_db(config['db_url_from']) | ||||
|     logger.info("Starting db migration.") | ||||
|  | ||||
|   | ||||
| @@ -54,10 +54,12 @@ def init_db(db_url: str) -> None: | ||||
|     # https://docs.sqlalchemy.org/en/13/orm/contextual.html#thread-local-scope | ||||
|     # Scoped sessions proxy requests to the appropriate thread-local session. | ||||
|     # We should use the scoped_session object - not a seperately initialized version | ||||
|     Trade._session = scoped_session(sessionmaker(bind=engine, autoflush=False)) | ||||
|     Trade.query = Trade._session.query_property() | ||||
|     Order.query = Trade._session.query_property() | ||||
|     PairLock.query = Trade._session.query_property() | ||||
|     Trade.session = scoped_session(sessionmaker(bind=engine, autoflush=False)) | ||||
|     Order.session = Trade.session | ||||
|     PairLock.session = Trade.session | ||||
|     Trade.query = Trade.session.query_property() | ||||
|     Order.query = Trade.session.query_property() | ||||
|     PairLock.query = Trade.session.query_property() | ||||
|  | ||||
|     previous_tables = inspect(engine).get_table_names() | ||||
|     ModelBase.metadata.create_all(engine) | ||||
|   | ||||
| @@ -22,7 +22,7 @@ def test_init_create_session(default_conf): | ||||
|     # Check if init create a session | ||||
|     init_db(default_conf['db_url']) | ||||
|     assert hasattr(Trade, '_session') | ||||
|     assert 'scoped_session' in type(Trade._session).__name__ | ||||
|     assert 'scoped_session' in type(Trade.session).__name__ | ||||
|  | ||||
|  | ||||
| def test_init_custom_db_url(default_conf, tmpdir): | ||||
| @@ -34,7 +34,7 @@ def test_init_custom_db_url(default_conf, tmpdir): | ||||
|  | ||||
|     init_db(default_conf['db_url']) | ||||
|     assert Path(filename).is_file() | ||||
|     r = Trade._session.execute(text("PRAGMA journal_mode")) | ||||
|     r = Trade.session.execute(text("PRAGMA journal_mode")) | ||||
|     assert r.first() == ('wal',) | ||||
|  | ||||
|  | ||||
|   | ||||
		Reference in New Issue
	
	Block a user