-from lcm.pub.database.models import NfInstModel, VmInstModel, VNFCInstModel
+from lcm.pub.database.models import NfInstModel
+from lcm.pub.database.models import VmInstModel
+from lcm.pub.database.models import VNFCInstModel
from lcm.pub.utils.timeutil import now_time
from lcm.pub.utils.values import ignore_case_get
from lcm.pub.vimapi import adaptor
from lcm.nf.biz.grant_vnf import grant_resource
from lcm.nf.const import VNF_STATUS, GRANT_TYPE, OPERATION_STATE_TYPE, LCM_NOTIFICATION_STATUS
from lcm.nf.const import CHANGE_TYPE, OPERATION_TYPE, HEAL_ACTION_TYPE
from lcm.pub.utils.timeutil import now_time
from lcm.pub.utils.values import ignore_case_get
from lcm.pub.vimapi import adaptor
from lcm.nf.biz.grant_vnf import grant_resource
from lcm.nf.const import VNF_STATUS, GRANT_TYPE, OPERATION_STATE_TYPE, LCM_NOTIFICATION_STATUS
from lcm.nf.const import CHANGE_TYPE, OPERATION_TYPE, HEAL_ACTION_TYPE
self.grant_type = GRANT_TYPE.HEAL_CREATE
elif self.action == HEAL_ACTION_TYPE.RESTART:
self.grant_type = GRANT_TYPE.HEAL_RESTART
self.grant_type = GRANT_TYPE.HEAL_CREATE
elif self.action == HEAL_ACTION_TYPE.RESTART:
self.grant_type = GRANT_TYPE.HEAL_RESTART
+ self.lcm_op_occ = VnfLcmOpOcc(
+ vnf_inst_id=nf_inst_id,
+ lcm_op_id=job_id,
+ operation=OPERATION_TYPE.HEAL,
+ task=OPERATION_TASK.HEAL
+ )
- NfInstModel.objects.filter(nfinstid=self.nf_inst_id).update(status='INSTANTIATED', lastuptime=now_time())
- self.lcm_notify(LCM_NOTIFICATION_STATUS.RESULT, OPERATION_STATE_TYPE.COMPLETED)
+ NfInstModel.objects.filter(nfinstid=self.nf_inst_id).update(
+ status='INSTANTIATED',
+ lastuptime=now_time()
+ )
+ self.lcm_notify(
+ LCM_NOTIFICATION_STATUS.RESULT,
+ OPERATION_STATE_TYPE.COMPLETED
+ )
- self.lcm_notify(LCM_NOTIFICATION_STATUS.RESULT, OPERATION_STATE_TYPE.FAILED, str(e))
- self.vnf_heal_failed_handle(traceback.format_exc())
+ logger.error(traceback.format_exc())
+ self.vnf_heal_failed_handle(e.message)
def vnf_heal_failed_handle(self, error_msg):
logger.error('VNF Healing failed, detail message: %s' % error_msg)
def vnf_heal_failed_handle(self, error_msg):
logger.error('VNF Healing failed, detail message: %s' % error_msg)
- NfInstModel.objects.filter(nfinstid=self.nf_inst_id).update(status=VNF_STATUS.FAILED, lastuptime=now_time())
+ NfInstModel.objects.filter(nfinstid=self.nf_inst_id).update(
+ status=VNF_STATUS.FAILED,
+ lastuptime=now_time()
+ )
+ self.lcm_op_occ.notify_lcm(OPERATION_STATE_TYPE.FAILED, error_msg)
JobUtil.add_job_status(self.job_id, 255, error_msg)
def lcm_notify(self, status, opState, err=None):
JobUtil.add_job_status(self.job_id, 255, error_msg)
def lcm_notify(self, status, opState, err=None):