X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2app%2Fbootstrap.py;h=e025a9058a4a8044309444865d5ff33b798a0bbf;hb=refs%2Ftags%2F2.0.0-rc2;hp=2e907686cccba7825de52fb3edd612aaada9dc28;hpb=84867b76a65efc4e9add52c86eae7e451c4a038d;p=pti%2Fo2.git diff --git a/o2app/bootstrap.py b/o2app/bootstrap.py index 2e90768..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__) @@ -54,6 +55,7 @@ def bootstrap( 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) @@ -72,11 +74,13 @@ def bootstrap( 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, ) + messagebus.MessageBus.set_instance(bus) + return bus def inject_dependencies(handler, dependencies):