X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2ims%2Fservice%2Funit_of_work.py;h=04459962a734f4ae79f196712189459cc3a4affe;hb=19ee63847f8eb032009e63634b90eb594f3c0408;hp=f329ebc87384de1bcf230b5e6b67a93f022721ac;hpb=b21c925328b0c700fde9001b7a56ea55decdf088;p=pti%2Fo2.git diff --git a/o2ims/service/unit_of_work.py b/o2ims/service/unit_of_work.py index f329ebc..0445996 100644 --- a/o2ims/service/unit_of_work.py +++ b/o2ims/service/unit_of_work.py @@ -17,7 +17,8 @@ from __future__ import annotations import abc from o2ims.domain.ocloud_repo import OcloudRepository,\ - ResourcePoolRepository, ResourceRepository, ResourceTypeRepository + ResourcePoolRepository, ResourceRepository, ResourceTypeRepository,\ + DeploymentManagerRepository from o2ims.domain.stx_repo import StxObjectRepository @@ -26,6 +27,7 @@ class AbstractUnitOfWork(abc.ABC): resource_types: ResourceTypeRepository resource_pools: ResourcePoolRepository resources: ResourceRepository + deployment_managers: DeploymentManagerRepository stxobjects: StxObjectRepository def __enter__(self): @@ -50,7 +52,10 @@ class AbstractUnitOfWork(abc.ABC): for entry in self.resource_types.seen: while entry.events: yield entry.events.pop(0) - for entry in self.stxobjects.seen: + # for entry in self.stxobjects.seen: + # while entry.events: + # yield entry.events.pop(0) + for entry in self.deployment_managers.seen: while entry.events: yield entry.events.pop(0)