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
Fix INF-378 inventory subscription filter upgrade
[pti/o2.git]
/
o2app
/
bootstrap.py
diff --git
a/o2app/bootstrap.py
b/o2app/bootstrap.py
index
2e90768
..
e025a90
100644
(file)
--- 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 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__)
from o2common.helper import o2logging
logger = o2logging.get_logger(__name__)
@@
-54,6
+55,7
@@
def bootstrap(
with uow:
# get default engine if uow is by default
engine = uow.session.get_bind()
with uow:
# get default engine if uow is by default
engine = uow.session.get_bind()
+
wait_for_db_ready(engine)
o2ims_orm.start_o2ims_mappers(engine)
o2dms_orm.start_o2dms_mappers(engine)
wait_for_db_ready(engine)
o2ims_orm.start_o2ims_mappers(engine)
o2dms_orm.start_o2dms_mappers(engine)
@@
-72,11
+74,13
@@
def bootstrap(
for command_type, handler in handlers.COMMAND_HANDLERS.items()
}
for command_type, handler in handlers.COMMAND_HANDLERS.items()
}
-
return
messagebus.MessageBus(
+
bus =
messagebus.MessageBus(
uow=uow,
event_handlers=injected_event_handlers,
command_handlers=injected_command_handlers,
)
uow=uow,
event_handlers=injected_event_handlers,
command_handlers=injected_command_handlers,
)
+ messagebus.MessageBus.set_instance(bus)
+ return bus
def inject_dependencies(handler, dependencies):
def inject_dependencies(handler, dependencies):