diff --git a/monasca_api/common/repositories/sqla/sql_repository.py b/monasca_api/common/repositories/sqla/sql_repository.py index 231c6cf28..fdd148c78 100644 --- a/monasca_api/common/repositories/sqla/sql_repository.py +++ b/monasca_api/common/repositories/sqla/sql_repository.py @@ -62,7 +62,9 @@ def get_engine(use_slave=False, connection=None): :param connection: The database connection string """ ctxt_mgr = create_context_manager(connection=connection) - return ctxt_mgr.get_legacy_facade().get_engine(use_slave=use_slave) + if use_slave: + return ctxt_mgr.reader.get_engine() + return ctxt_mgr.writer.get_engine() class SQLRepository(object):