Add ocloud query parameter; add and delete subscription

[pti/o2.git] / o2ims / adapter / ocloud_repository.py

diff --git a/o2ims/adapter/ocloud_repository.py b/o2ims/adapter/ocloud_repository.py
index 4d4361c..0826cf0 100644 (file)
--- a/o2ims/adapter/ocloud_repository.py
+++ b/o2ims/adapter/ocloud_repository.py
@@ -134,3 +134,7 @@ class SubscriptionSqlAlchemyRepository(SubscriptionRepository):
 
     def _update(self, subscription: ocloud.Subscription):
         self.session.add(subscription)
+
+    def _delete(self, subscription_id):
+        self.session.query(ocloud.Subscription).filter_by(
+            subscriptionId=subscription_id).delete()