X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2app%2Fadapter%2Funit_of_work.py;h=e4885423e9b2ff20868d02453676c7fe24045bb2;hb=7fb3d02a3744ecb368b0531f16175034b987d42f;hp=0faba563279343be552b709c669ee6b3fd2549eb;hpb=5e02e76308e1677fb106572b885a366eb6c0fbec;p=pti%2Fo2.git diff --git a/o2app/adapter/unit_of_work.py b/o2app/adapter/unit_of_work.py index 0faba56..e488542 100644 --- a/o2app/adapter/unit_of_work.py +++ b/o2app/adapter/unit_of_work.py @@ -46,10 +46,16 @@ class SqlAlchemyUnitOfWork(AbstractUnitOfWork): .ResourcePoolSqlAlchemyRepository(self.session) self.resources = ocloud_repository\ .ResourceSqlAlchemyRepository(self.session) + self.subscriptions = ocloud_repository\ + .SubscriptionSqlAlchemyRepository(self.session) self.deployment_managers = ocloud_repository\ .DeploymentManagerSqlAlchemyRepository(self.session) self.nfdeployment_descs = dms_repository\ .NfDeploymentDescSqlAlchemyRepository(self.session) + self.nfdeployments = dms_repository\ + .NfDeploymentSqlAlchemyRepository(self.session) + self.ocloudvresources = dms_repository\ + .NfOCloudVResourceSqlAlchemyRepository(self.session) return super().__enter__() def __exit__(self, *args): @@ -81,3 +87,9 @@ class SqlAlchemyUnitOfWork(AbstractUnitOfWork): for entry in self.nfdeployment_descs.seen: while entry.events: yield entry.events.pop(0) + for entry in self.nfdeployments.seen: + while entry.events: + yield entry.events.pop(0) + for entry in self.ocloudvresources.seen: + while entry.events: + yield entry.events.pop(0)