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/temporal/vnf_activities.py b/osm_lcm/temporal/vnf_activities.py
index 2602eeb..3e2155b 100644
--- a/osm_lcm/temporal/vnf_activities.py
+++ b/osm_lcm/temporal/vnf_activities.py
@@ -17,15 +17,15 @@
import logging
from temporalio import activity
from osm_common.temporal_constants import (
- ACTIVITY_CHANGE_NF_STATE,
- ACTIVITY_CHANGE_NF_INSTANTIATION_STATE,
- ACTIVITY_CHANGE_NF_NOTIFICATION_STATE,
+ ACTIVITY_CHANGE_VNF_STATE,
+ ACTIVITY_CHANGE_VNF_INSTANTIATION_STATE,
+ ACTIVITY_SEND_NOTIFICATION_FOR_VNF,
ACTIVITY_GET_TASK_QUEUE,
VIM_TYPE_TASK_QUEUE_MAPPINGS,
)
from osm_common.dataclasses.temporal_dataclasses import (
- ChangeNFInstantiationStateInput,
- ChangeNFStateInput,
+ ChangeVnfInstantiationStateInput,
+ ChangeVnfStateInput,
GetTaskQueueInput,
GetTaskQueueOutput,
)
@@ -79,8 +79,8 @@
self.db = db
self.logger = logging.getLogger(f"lcm.act.{self.__class__.__name__}")
- @activity.defn(name=ACTIVITY_CHANGE_NF_STATE)
- async def change_nf_state(self, nf_state_input: ChangeNFStateInput) -> None:
+ @activity.defn(name=ACTIVITY_CHANGE_VNF_STATE)
+ async def change_vnf_state(self, vnf_state_input: ChangeVnfStateInput) -> None:
"""Updates the VNF State in VNFR.
Collaborators:
@@ -101,15 +101,15 @@
activity, the operation is idempotent.
"""
- update_nf_state = {"vnfState": nf_state_input.nf_state}
- self.db.set_one("vnfrs", {"_id": nf_state_input.vnfr_uuid}, update_nf_state)
+ update_vnf_state = {"vnfState": vnf_state_input.state}
+ self.db.set_one("vnfrs", {"_id": vnf_state_input.vnfr_uuid}, update_vnf_state)
self.logger.debug(
- f"VNF {nf_state_input.vnfr_uuid} state is updated to {nf_state_input.nf_state}."
+ f"VNF {vnf_state_input.vnfr_uuid} state is updated to {vnf_state_input.state}."
)
- @activity.defn(name=ACTIVITY_CHANGE_NF_INSTANTIATION_STATE)
- async def change_nf_instantiation_state(
- self, nf_instantiation_state_input: ChangeNFInstantiationStateInput
+ @activity.defn(name=ACTIVITY_CHANGE_VNF_INSTANTIATION_STATE)
+ async def change_vnf_instantiation_state(
+ self, vnf_instantiation_state_input: ChangeVnfInstantiationStateInput
) -> None:
"""Updates the VNF Instantiation State in VNFR.
@@ -131,23 +131,30 @@
activity, the operation is idempotent.
"""
- update_nf_instantiation_state = {
- "vnfState": nf_instantiation_state_input.nf_instantiation_state
+ update_vnf_instantiation_state = {
+ "vnfState": vnf_instantiation_state_input.state
}
self.db.set_one(
"vnfrs",
- {"_id": nf_instantiation_state_input.vnfr_uuid},
- update_nf_instantiation_state,
+ {"_id": vnf_instantiation_state_input.vnfr_uuid},
+ update_vnf_instantiation_state,
)
self.logger.debug(
- f"VNF {nf_instantiation_state_input.vnfr_uuid} state is updated to {nf_instantiation_state_input.nf_instantiation_state}."
+ f"VNF {vnf_instantiation_state_input.vnfr_uuid} state is updated to {vnf_instantiation_state_input.state}."
)
- @activity.defn(name=ACTIVITY_CHANGE_NF_NOTIFICATION_STATE)
- async def change_nf_notification_state(self) -> None:
+
+class VnfSendNotifications:
+ """Perform Notification operations."""
+
+ def __init__(self):
+ self.logger = logging.getLogger(f"lcm.act.{self.__class__.__name__}")
+
+ @activity.defn(name=ACTIVITY_SEND_NOTIFICATION_FOR_VNF)
+ async def send_notification_for_vnf(self) -> None:
"""If VNF LCM operation state changes, send notification updates.
This activity does nothing.
"""
- pass
+ self.logger.debug("Send notification for VNF not implemented.")