JobUtil.add_job_status(job_id, 10, 'NS inst(%s) wso2 workflow started: %s' % (
self.ns_inst_id, ret.get('status')))
if ret.get('status') == 1:
- return dict(data={'jobId': job_id}, status=status.HTTP_200_OK)
+ return dict(data={'jobId': job_id}, status=status.HTTP_200_OK, occ_id=occ_id)
return dict(data={'error': ret['message']}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
def start_activiti_workflow(self, job_id, plan_input, occ_id):
InstantNsReq['locationConstraints'].append(vnf)
ack = InstantNSService(ns_instance_id, request.data).do_biz()
- nsLcmOpOccId = ack['occ_id']
+ nsLcmOpOccId = ack.get('occ_id')
+ if not nsLcmOpOccId:
+ return Response(data=ack['data'], status=ack['status'])
response = Response(data={}, status=status.HTTP_202_ACCEPTED)
logger.debug("Location: %s" % ack['occ_id'])
response["Location"] = NS_OCC_BASE_URI % nsLcmOpOccId