return {"result": 0, "detail": "sfc is not exist or has been already deleted"}
self.ns_inst_id = sfc_inst_info[0].nsinstid
self.delete_sfc_from_driver(sfc_inst_info[0])
- self.delete_sfc_from_resmgr()
+ # self.delete_sfc_from_resmgr()
self.delete_sfc_from_db(sfc_inst_info)
return {"result": 0, "detail": "delete sfc success"}
except NSLCMException as e:
try:
self.get_data()
self.create_vl_to_vim()
- self.create_vl_to_resmgr()
+ # self.create_vl_to_resmgr()
self.save_vl_to_db()
if REPORT_TO_AAI:
self.create_network_aai()
subnetwork_id_list = vl_inst_info[0].relatedsubnetworkid.split(",")
network_id = vl_inst_info[0].relatednetworkid
self.delete_vl_from_vim(vim_id, subnetwork_id_list, network_id)
- self.delete_vl_from_resmgr()
+ # self.delete_vl_from_resmgr()
if REPORT_TO_AAI:
self.delete_network_and_subnet_in_aai()
self.delete_vl_from_db(vl_inst_info)
self.send_nf_init_request_to_vnfm()
self.send_homing_request_to_OOF()
self.send_get_vnfm_request_to_extsys()
- self.send_create_vnf_request_to_resmgr()
+ # self.send_create_vnf_request_to_resmgr()
self.wait_vnfm_job_finish()
self.subscribe()
- self.write_vnf_creation_info()
+ # self.write_vnf_creation_info()
self.save_info_to_db()
JobUtil.add_job_status(self.job_id, JOB_PROGRESS.FINISHED, 'vnf instantiation success', JOB_ERROR_CODE.NO_ERROR)
except NSLCMException as e:
from lcm.pub.exceptions import NSLCMException
from lcm.pub.msapi.sdc_run_catalog import query_vnfpackage_by_id
from lcm.pub.utils.values import ignore_case_get
-from lcm.pub.msapi import resmgr
from lcm.ns_vnfs.const import SCALAR_UNIT_DICT
logger = logging.getLogger(__name__)
break
req_param[grant_type].append(grant_res)
self.data = req_param
- tmp = resmgr.grant_vnf(self.data)
- vimConnections.append(
- {
- "id": tmp["vim"]["vimId"],
- "vimId": tmp["vim"]["vimId"],
- "vimType": None,
- "interfaceInfo": None,
- "accessInfo": tmp["vim"]["accessInfo"],
- "extra": None
- }
- )
+ # tmp = resmgr.grant_vnf(self.data)
+ # vimConnections.append(
+ # {
+ # "id": tmp["vim"]["vimId"],
+ # "vimId": tmp["vim"]["vimId"],
+ # "vimType": None,
+ # "interfaceInfo": None,
+ # "accessInfo": tmp["vim"]["accessInfo"],
+ # "extra": None
+ # }
+ # )
grant_resp = {
"id": str(uuid.uuid4()),
self.check_nf_valid()
self.send_nf_terminate_to_vnfmDriver()
self.wait_vnfm_job_finish()
- self.send_terminate_vnf_to_resMgr()
+ # self.send_terminate_vnf_to_resMgr()
if REPORT_TO_AAI:
self.delete_vserver_in_aai()
self.delete_vnf_in_aai()
resp = GrantVnf(json.dumps(self.data)).exec_grant()
self.assertEqual(resp["vnfInstanceId"], "add_resources_but_no_off")
self.assertEqual(resp["vnfLcmOpOccId"], "vnf_lcm_op_occ_id")
- vimConnections = [{
- "id": "cloudOwner_casa",
- "vimId": "cloudOwner_casa",
- "vimType": None,
- "interfaceInfo": None,
- "accessInfo": {"tenant": "tenantA"},
- "extra": None
- }]
+ vimConnections = []
self.assertEqual(resp["vimConnections"], vimConnections)
@mock.patch.object(resmgr, "grant_vnf")
resp = GrantVnf(json.dumps(self.data)).exec_grant()
self.assertEqual(resp["vnfInstanceId"], "remove_resources_but_no_off")
self.assertEqual(resp["vnfLcmOpOccId"], "vnf_lcm_op_occ_id")
- vimConnections = [{
- "id": "cloudOwner_casa",
- "vimId": "cloudOwner_casa",
- "vimType": None,
- "interfaceInfo": None,
- "accessInfo": {"tenant": "tenantA"},
- "extra": None
- }]
+ vimConnections = []
self.assertEqual(resp["vimConnections"], vimConnections)
@mock.patch.object(resmgr, "grant_vnf")
raise ex
except urllib.error.URLError as err:
ret = [2, str(err), resp_status, resp_Location]
- except Exception as ex:
+ except Exception:
logger.error(traceback.format_exc())
logger.error("[%s]ret=%s" % (callid, str(sys.exc_info())))
res_info = str(sys.exc_info())
[flake8]
ignore = E501,E722
-exclude = ./venv-tox,./.tox
+exclude = ./venv-tox,./.tox,./venv
max-complexity = 27
[testenv]