Code Review
/
pti
/
o2.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Add helm chart for ca and config files.
[pti/o2.git]
/
o2app
/
bootstrap.py
diff --git
a/o2app/bootstrap.py
b/o2app/bootstrap.py
index
4413e80
..
228b240
100644
(file)
--- 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.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
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 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__)
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")
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(),
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)
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}
dependencies = {"uow": uow, "notifications": notifications,
"publish": publish}