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
Validate nfdeployment descriptor params
[pti/o2.git]
/
o2app
/
bootstrap.py
diff --git
a/o2app/bootstrap.py
b/o2app/bootstrap.py
index
4413e80
..
329d9e2
100644
(file)
--- a/
o2app/bootstrap.py
+++ b/
o2app/bootstrap.py
@@
-40,15
+40,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
+56,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}