X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2ims%2Fadapter%2Focloud_repository.py;fp=src%2Fo2ims%2Fadapter%2Focloud_repository.py;h=8a547fe96d4f3ff29654ab9e71a1024482ff4261;hb=81e3575a77366f30c2049f98c48a3087db0ea992;hp=6d3d221a90cb6f392045bbaefe49a406a2b6faa4;hpb=8339c9a882a586578b37f44a504e21c5208611c0;p=pti%2Fo2.git diff --git a/src/o2ims/adapter/ocloud_repository.py b/o2ims/adapter/ocloud_repository.py similarity index 88% rename from src/o2ims/adapter/ocloud_repository.py rename to o2ims/adapter/ocloud_repository.py index 6d3d221..8a547fe 100644 --- a/src/o2ims/adapter/ocloud_repository.py +++ b/o2ims/adapter/ocloud_repository.py @@ -14,9 +14,10 @@ import abc from typing import Set -from o2ims.adapter import orm +# from o2ims.adapter import orm from o2ims.domain import ocloud + class OcloudRepository(abc.ABC): def __init__(self): self.seen = set() # type: Set[ocloud.Ocloud] @@ -30,7 +31,7 @@ class OcloudRepository(abc.ABC): if ocloud: self.seen.add(ocloud) return ocloud - + def update(self, ocloud: ocloud.Ocloud): self._update(ocloud) @@ -60,7 +61,8 @@ class OcloudSqlAlchemyRepository(OcloudRepository): # self.session.add_all(ocloud.deploymentManagers) def _get(self, ocloudid) -> ocloud.Ocloud: - return self.session.query(ocloud.Ocloud).filter_by(oCloudId=ocloudid).first() + return self.session.query(ocloud.Ocloud).filter_by( + oCloudId=ocloudid).first() def _update(self, ocloud: ocloud.Ocloud): self.session.add(ocloud) @@ -70,8 +72,10 @@ class OcloudSqlAlchemyRepository(OcloudRepository): # if dmslist: # self._update_dms_list(dmslist) # if updatefields: - # self.session.query(ocloud.Ocloud).filter_by(oCloudId=ocloudid).update(updatefields) + # self.session.query(ocloud.Ocloud).filter_by( + # oCloudId=ocloudid).update(updatefields) # def _update_dms_list(self, dms_list: list): # for dms in dms_list or []: - # self.session.query(ocloud.DeploymentManager).filter_by(deploymentManagerId=dms.deploymentManagerId).update(dms) + # self.session.query(ocloud.DeploymentManager).filter_by( + # deploymentManagerId=dms.deploymentManagerId).update(dms)