From 58d41110f5432e5c86715c22b7026cab6685e0b4 Mon Sep 17 00:00:00 2001 From: jiasirui Date: Wed, 21 Dec 2022 22:51:56 +0800 Subject: [PATCH] remove duplicated function Change-Id: Ic37a1c7ead6a4f3b4186d35bb459fb3c9f868bd5 --- venus/modules/custom_config/backends/sql.py | 44 +-------------------- 1 file changed, 1 insertion(+), 43 deletions(-) diff --git a/venus/modules/custom_config/backends/sql.py b/venus/modules/custom_config/backends/sql.py index 01ebb5e..00e41f1 100644 --- a/venus/modules/custom_config/backends/sql.py +++ b/venus/modules/custom_config/backends/sql.py @@ -14,53 +14,11 @@ """Implementation of SQLAlchemy backend.""" -import sqlalchemy - -import threading - import time - -from oslo_config import cfg - -from oslo_db import options - -from oslo_db.sqlalchemy import session as db_session - -from oslo_log import log as logging - -import osprofiler.sqlalchemy - +from venus.db.sqlalchemy.api import _create_facade_lazily from venus.modules.custom_config.backends import models -CONF = cfg.CONF -CONF.import_group("profiler", "venus.service") -log = logging.getLogger(__name__) -options.set_defaults(CONF, connection='sqlite:///$state_path/venus.sqlite') - -_LOCK = threading.Lock() -_FACADE = None - - -def _create_facade_lazily(): - global _LOCK - with _LOCK: - global _FACADE - if _FACADE is None: - _FACADE = db_session.EngineFacade( - CONF.database.connection, - **dict(CONF.database) - ) - - if CONF.profiler.profiler_enabled: - if CONF.profiler.trace_sqlalchemy: - osprofiler.sqlalchemy.add_tracing(sqlalchemy, - _FACADE.get_engine(), - "db") - - return _FACADE - - def get_session(**kwargs): facade = _create_facade_lazily() return facade.get_session(**kwargs)