X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2ims%2Fadapter%2Focloud_repository.py;h=ff1cd27b54f4f44a074e34281aa12c2d95da0930;hb=91c02b447f2035ffbb11891ece162242c8f5a44f;hp=8b54f53fa6f19e05a5b4d6050bef194c1849665a;hpb=7ee63c4b8ad2bbc661ba9b4f39f66abe94b591ae;p=pti%2Fo2.git diff --git a/o2ims/adapter/ocloud_repository.py b/o2ims/adapter/ocloud_repository.py index 8b54f53..ff1cd27 100644 --- a/o2ims/adapter/ocloud_repository.py +++ b/o2ims/adapter/ocloud_repository.py @@ -55,6 +55,10 @@ class ResouceTypeSqlAlchemyRepository(ResourceTypeRepository): return self.session.query(ocloud.ResourceType).filter_by( resourceTypeId=resource_type_id).first() + def _get_by_name(self, resource_type_name) -> ocloud.ResourceType: + return self.session.query(ocloud.ResourceType).filter_by( + name=resource_type_name).first() + def _list(self) -> List[ocloud.ResourceType]: return self.session.query(ocloud.ResourceType) @@ -112,9 +116,9 @@ class ResourceSqlAlchemyRepository(ResourceRepository): return res return recursive(resource_id) - def _list(self, resourcepool_id) -> List[ocloud.Resource]: + def _list(self, resourcepool_id, **kwargs) -> List[ocloud.Resource]: return self.session.query(ocloud.Resource).filter_by( - resourcePoolId=resourcepool_id) + resourcePoolId=resourcepool_id, **kwargs) def _update(self, resource: ocloud.Resource): self.session.add(resource)