JobUtil.add_job_status(job_id, 5, 'Start query nsd(%s)' % ns_inst.nspackage_id)
dst_plan = None
if WORKFLOW_OPTION == "wso2":
src_plan = query_rawdata_from_catalog(ns_inst.nspackage_id, input_parameters)
dst_plan = toscautil.convert_nsd_model(src_plan["rawData"])
else:
JobUtil.add_job_status(job_id, 5, 'Start query nsd(%s)' % ns_inst.nspackage_id)
dst_plan = None
if WORKFLOW_OPTION == "wso2":
src_plan = query_rawdata_from_catalog(ns_inst.nspackage_id, input_parameters)
dst_plan = toscautil.convert_nsd_model(src_plan["rawData"])
else: