operation_state=OPERATION_STATE_TYPE.COMPLETED
)
except NFLCMException as e:
- logger.error(e.message)
- self.change_ext_conn_failed_handle(e.message)
+ logger.error(e.args[0])
+ self.change_ext_conn_failed_handle(e.args[0])
except Exception as e:
- logger.error(e.message)
+ logger.error(e.args[0])
logger.error(traceback.format_exc())
- self.change_ext_conn_failed_handle(e.message)
+ self.change_ext_conn_failed_handle(e.args[0])
def pre_deal(self):
logger.debug("Start pre deal for VNF change_ext_conn task")
"location_info": {
"vimid": vim_id,
"tenant": tenant
- }
+ },
+ # TODO need confirm
+ "protocol_data": [
+ {
+ "address_data": {
+ "l3_address_data": {
+ "fixed_ip_address":
+ {"ip_address_assignment": True,
+ "floating_ip_activated": True,
+ "ip_address_type": "IPV4",
+ "number_of_ip_address": 1}
+ },
+ },
+ },
+ ],
},
"vl_id": network_id,
"vdu_id": vdu_id,
def query_inst_resource(self, inst_resource):
logger.debug('Query resource begin')
- for resource_type in RESOURCE_MAP.keys():
+ for resource_type in list(RESOURCE_MAP.keys()):
resource_table = globals().get(resource_type + 'InstModel')
resource_insts = resource_table.objects.filter(
instid=self.nf_inst_id
def do_create_port_notify(self, res_type, ret):
self.port_id = ignore_case_get(ret, "id")
- port_save("", self.nf_inst_id, ret)
+ port_save(self.job_id, self.nf_inst_id, ret)
def do_notify_op(self, operation_type, status, resid):
if operation_type == "delete":