- job_id = JobUtil.create_job(JOB_TYPE.NS, JOB_ACTION.MANUAL_SCALE, ns_instance_id)
- try:
- req_serializer = _ManualScaleNsReqSerializer(data=request.data)
- if not req_serializer.is_valid():
- raise NSLCMException(req_serializer.errors)
- req = request.data
- scale_data = {}
- scale_data['scaleType'] = req['scaleType']
- scaleNsData = req['scaleNsData'][0]
- scale_data['scaleNsData'] = {"scaleNsByStepsData": scaleNsData['scaleNsByStepsData'][0]}
- NSManualScaleService(ns_instance_id, scale_data, job_id).start()
-
- resp_serializer = _NsOperateJobSerializer(data={'jobId': job_id})
- if not resp_serializer.is_valid():
- raise NSLCMException(resp_serializer.errors)
-
- return Response(data=resp_serializer.data, status=status.HTTP_202_ACCEPTED)
- except Exception as e:
- logger.error(traceback.format_exc())
- JobUtil.add_job_status(job_id, 255, 'NS scale failed: %s' % e.args[0])
- return Response(data={'error': 'NS scale failed: %s' % ns_instance_id},
- status=status.HTTP_500_INTERNAL_SERVER_ERROR)
+ req_serializer = _ManualScaleNsReqSerializer(data=request.data)
+ if not req_serializer.is_valid():
+ raise NSLCMException(req_serializer.errors)
+
+ req = request.data
+ scale_data = {}
+ scale_data['scaleType'] = req['scaleType']
+ scaleNsData = req['scaleNsData'][0]
+ scale_data['scaleNsData'] = {
+ "scaleNsByStepsData": scaleNsData['scaleNsByStepsData'][0]
+ }
+ job_id = JobUtil.create_job(
+ JOB_TYPE.NS,
+ JOB_ACTION.MANUAL_SCALE,
+ ns_instance_id
+ )
+ NSManualScaleService(ns_instance_id, scale_data, job_id).start()
+
+ resp_serializer = _NsOperateJobSerializer(data={'jobId': job_id})
+ if not resp_serializer.is_valid():
+ raise NSLCMException(resp_serializer.errors)
+
+ return Response(data=resp_serializer.data, status=status.HTTP_202_ACCEPTED)