X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2app%2Fbootstrap.py;h=228b240d1ee714670ba8619bc7e87ab926dfbd97;hb=refs%2Fchanges%2F55%2F9355%2F2;hp=4413e80d4706565813e74ad7270b42a9b6728ff7;hpb=659a526fb149407f1bc7c598e1943195915dcbd6;p=pti%2Fo2.git diff --git a/o2app/bootstrap.py b/o2app/bootstrap.py index 4413e80..228b240 100644 --- a/o2app/bootstrap.py +++ b/o2app/bootstrap.py @@ -21,6 +21,7 @@ from o2common.adapter.notifications import AbstractNotifications,\ from o2common.adapter import redis_eventpublisher from o2common.service import unit_of_work from o2common.service import messagebus +from o2common.config import config from o2app.service import handlers from o2app.adapter.unit_of_work import SqlAlchemyUnitOfWork @@ -28,6 +29,9 @@ from o2app.adapter.unit_of_work import SqlAlchemyUnitOfWork from o2ims.adapter import orm as o2ims_orm from o2dms.adapter import orm as o2dms_orm +from o2ims.adapter.clients import alarm_dict_client + + from o2common.helper import o2logging logger = o2logging.get_logger(__name__) @@ -40,15 +44,6 @@ def wait_for_db_ready(engine): logger.info("DB is ready") -@retry(tries=3, delay=2) -def wait_for_mappers_ready(engine): - # wait for mapper ready - logger.info("Wait for mapper ready ...") - o2ims_orm.start_o2ims_mappers(engine) - o2dms_orm.start_o2dms_mappers(engine) - logger.info("mapper is ready") - - def bootstrap( start_orm: bool = True, uow: unit_of_work.AbstractUnitOfWork = SqlAlchemyUnitOfWork(), @@ -65,7 +60,8 @@ def bootstrap( engine = uow.session.get_bind() wait_for_db_ready(engine) - wait_for_mappers_ready(engine) + o2ims_orm.start_o2ims_mappers(engine) + o2dms_orm.start_o2dms_mappers(engine) dependencies = {"uow": uow, "notifications": notifications, "publish": publish}