+ key = "vnfInstanceName"
+ try:
+ self.lcm_op_occ.notify_lcm(OPERATION_STATE_TYPE.PROCESSING)
+ JobUtil.add_job_status(self.job_id, 50, "Start updating VNF.")
+
+ if key in self.data and self.data[key] is not None:
+ self.vnf_insts.update(nf_name=self.data[key],
+ lastuptime=now_time())
+
+ key = "vnfInstanceDescription"
+ if key in self.data and self.data[key] is not None:
+ self.vnf_insts.update(nf_desc=self.data[key],
+ lastuptime=now_time())
+
+ key = "vnfPkgId"
+ if key in self.data:
+ self.vnf_insts.update(vnfdid=self.data[key],
+ lastuptime=now_time())
+
+ JobUtil.add_job_status(self.job_id, 75, "Start sending notification.")
+ self.send_notification()
+
+ JobUtil.add_job_status(self.job_id, 100, "Update VNF success.")
+ except NFLCMException as e:
+ logger.error(e.args[0])
+ self.lcm_op_occ.notify_lcm(OPERATION_STATE_TYPE.FAILED, e.args[0])
+ JobUtil.add_job_status(self.job_id, 255, e.args[0])
+ except Exception as e:
+ logger.error(e.args[0])
+ logger.error(traceback.format_exc())
+ self.lcm_op_occ.notify_lcm(OPERATION_STATE_TYPE.FAILED, e.args[0])
+ JobUtil.add_job_status(self.job_id, 255, e.args[0])
+
+ def send_notification(self):
+ notify_data = prepare_notification(nfinstid=self.nf_inst_id,
+ jobid=self.job_id,
+ operation=OPERATION_TYPE.MODIFY_INFO,
+ operation_state=OPERATION_STATE_TYPE.COMPLETED)
+
+ notify_data["changedInfo"] = {}
+ for key in ("vnfInstanceName", "vnfInstanceDescription"):
+ if key in self.data and self.data[key] is not None:
+ notify_data["changedInfo"][key] = self.data[key]
+
+ logger.debug('Notification data: %s' % notify_data)
+ NotificationsUtil().send_notification(notify_data)