OSMENG-1006 Implement Instantiate VNF Workflow
Change-Id: I12ce8268b949e4f5e901001059a088edb230258b
Signed-off-by: Gulsum Atici <gulsum.atici@canonical.com>
Signed-off-by: Mark Beierl <mark.beierl@canonical.com>
diff --git a/osm_lcm/temporal/vnf_activities.py b/osm_lcm/temporal/vnf_activities.py
index 16cc93c..95b4232 100644
--- a/osm_lcm/temporal/vnf_activities.py
+++ b/osm_lcm/temporal/vnf_activities.py
@@ -67,7 +67,7 @@
"""
vnfr = self.db.get_one("vnfrs", {"_id": get_task_queue_input.vnfr_uuid})
vim_record = self.db.get_one("vim_accounts", {"_id": vnfr["vim-account-id"]})
- task_queue = VIM_TYPE_TASK_QUEUE_MAPPINGS[vim_record["vim-type"]]
+ task_queue = VIM_TYPE_TASK_QUEUE_MAPPINGS[vim_record["vim_type"]]
self.logger.debug(f"Got the task queue {task_queue} for VNF operations.")
return GetTaskQueueOutput(task_queue)
@@ -213,7 +213,9 @@
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:
+ async def send_notification_for_vnf(
+ self, input: ChangeVnfInstantiationStateInput
+ ) -> None:
"""If VNF LCM operation state changes, send notification updates.
This activity does nothing.