X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2app%2Fbootstrap.py;h=e025a9058a4a8044309444865d5ff33b798a0bbf;hb=311537b9d3d9d20120686daf9e867f947c5d1274;hp=4413e80d4706565813e74ad7270b42a9b6728ff7;hpb=659a526fb149407f1bc7c598e1943195915dcbd6;p=pti%2Fo2.git diff --git a/o2app/bootstrap.py b/o2app/bootstrap.py index 4413e80..e025a90 100644 --- a/o2app/bootstrap.py +++ b/o2app/bootstrap.py @@ -28,6 +28,7 @@ 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 o2common.helper import o2logging logger = o2logging.get_logger(__name__) @@ -40,15 +41,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 +57,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}