OSMENG-988: Create ACTIVITY_SEND_NOTIFICATION_FOR_NF
Change-Id: I3238f9c2486c052caa614079c5c680b90d7f6f3c
Signed-off-by: Dario Faccin <dario.faccin@canonical.com>
diff --git a/osm_lcm/nglcm.py b/osm_lcm/nglcm.py
index 6627bc8..781a5bd 100644
--- a/osm_lcm/nglcm.py
+++ b/osm_lcm/nglcm.py
@@ -41,7 +41,11 @@
)
from osm_lcm.temporal.vdu_workflows import VduInstantiateWorkflow
from osm_lcm.temporal.vnf_workflows import VnfInstantiateWorkflow
-from osm_lcm.temporal.vnf_activities import VnfDbActivity, VnfOperations
+from osm_lcm.temporal.vnf_activities import (
+ VnfDbActivity,
+ VnfOperations,
+ VnfSendNotifications,
+)
from osm_lcm.temporal.ns_workflows import NsInstantiateWorkflow
from osm_lcm.temporal.ns_activities import NsOperations, NsDbActivity
from temporalio.client import Client
@@ -141,6 +145,7 @@
vim_data_activity_instance = VimDbActivity(self.db)
vnf_data_activity_instance = VnfDbActivity(self.db)
vnf_operation_instance = VnfOperations(self.db)
+ vnf_send_notifications_instance = VnfSendNotifications()
workflows = [
NsInstantiateWorkflow,
@@ -167,9 +172,9 @@
vim_data_activity_instance.update_vim_state,
vim_data_activity_instance.delete_vim_record,
vnf_operation_instance.get_task_queue,
- vnf_data_activity_instance.change_nf_state,
- vnf_data_activity_instance.change_nf_instantiation_state,
- vnf_data_activity_instance.change_nf_notification_state,
+ vnf_data_activity_instance.change_vnf_state,
+ vnf_data_activity_instance.change_vnf_instantiation_state,
+ vnf_send_notifications_instance.send_notification_for_vnf,
]
# Check if we are running under a debugger