X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2ims%2Fviews%2Focloud_view.py;h=bc1109774834fd74f7a1ef2d9211f77e9757e063;hb=f9746f13be900f5ad7e9e2a9dbf7527e74b5d428;hp=2f115e206d47a0c17e4d654c0504b8d95deebc9d;hpb=cfd4a87b2d41223bbfaf67509ffe0a01f2e86736;p=pti%2Fo2.git diff --git a/o2ims/views/ocloud_view.py b/o2ims/views/ocloud_view.py index 2f115e2..bc11097 100644 --- a/o2ims/views/ocloud_view.py +++ b/o2ims/views/ocloud_view.py @@ -23,7 +23,8 @@ from o2common.service import unit_of_work from o2common.config import config from o2common.views.view import gen_filter, check_filter from o2common.views.pagination_view import Pagination -from o2common.views.route_exception import BadRequestException +from o2common.views.route_exception import BadRequestException, \ + NotFoundException from o2ims.domain import ocloud from o2ims.views.ocloud_dto import SubscriptionDTO @@ -241,7 +242,7 @@ def subscription_create(subscriptionDto: SubscriptionDTO.subscription_create, args.append(getattr(Subscription, 'filter') == filter) args.append(getattr(Subscription, 'consumerSubscriptionId') == consumer_subs_id) - count, _ = uow.alarm_subscriptions.list_with_count(*args) + count, _ = uow.subscriptions.list_with_count(*args) if count > 0: raise BadRequestException("The value of parameters is duplicated") uow.subscriptions.add(subscription) @@ -253,6 +254,10 @@ def subscription_create(subscriptionDto: SubscriptionDTO.subscription_create, def subscription_delete(subscriptionId: str, uow: unit_of_work.AbstractUnitOfWork): with uow: + first = uow.subscriptions.get(subscriptionId) + if not first: + raise NotFoundException( + "Subscription {} not found.".format(subscriptionId)) uow.subscriptions.delete(subscriptionId) uow.commit() return True