diff options
-rw-r--r-- | lcm/ns/views/sol/heal_ns_view.py | 33 | ||||
-rw-r--r-- | lcm/pub/enum.py | 5 |
2 files changed, 19 insertions, 19 deletions
diff --git a/lcm/ns/views/sol/heal_ns_view.py b/lcm/ns/views/sol/heal_ns_view.py index 6dfef8d1..58418bd7 100644 --- a/lcm/ns/views/sol/heal_ns_view.py +++ b/lcm/ns/views/sol/heal_ns_view.py @@ -12,18 +12,19 @@ # See the License for the specific language governing permissions and # limitations under the License. import logging + +from .common import view_safe_call_with_log from drf_yasg.utils import swagger_auto_schema -from rest_framework import status -from rest_framework.response import Response -from rest_framework.views import APIView from lcm.ns.biz.ns_heal import NSHealService -from lcm.ns.serializers.sol.heal_serializers import HealNsReqSerializer -from lcm.pub.exceptions import BadRequestException -from lcm.pub.utils.jobutil import JobUtil -from lcm.pub.enum import JOB_TYPE from lcm.ns.const import NS_OCC_BASE_URI +from lcm.pub.enum import JOB_TYPE +from lcm.pub.exceptions import BadRequestException +from lcm.ns.serializers.sol.heal_serializers import HealNsReqSerializer from lcm.ns.serializers.sol.pub_serializers import ProblemDetailsSerializer -from .common import view_safe_call_with_log +from lcm.pub.utils.jobutil import JobUtil +from rest_framework import status +from rest_framework.response import Response +from rest_framework.views import APIView logger = logging.getLogger(__name__) @@ -38,19 +39,17 @@ class HealNSView(APIView): ) @view_safe_call_with_log(logger=logger) def post(self, request, ns_instance_id): - logger.debug("Enter HealNSView::post %s", request.data) - logger.debug("Enter HealNSView:: %s", ns_instance_id) + logger.debug("Enter HealNSView::post nsInstanceId:%s, request.data:%s" % (ns_instance_id, request.data)) req_serializer = HealNsReqSerializer(data=request.data) if not req_serializer.is_valid(): - logger.debug("request.data is not valid,error: %s" % req_serializer.errors) + logger.error("request.data is not valid,error: %s" % req_serializer.errors) raise BadRequestException(req_serializer.errors) - job_id = JobUtil.create_job("VNF", JOB_TYPE.HEAL_VNF, ns_instance_id) - - nsHealService = NSHealService(ns_instance_id, request.data, job_id) - nsHealService.start() + job_id = JobUtil.create_job("NS", JOB_TYPE.HEAL_NS, ns_instance_id) + ns_heal_service = NSHealService(ns_instance_id, request.data, job_id) + ns_heal_service.start() response = Response(data={}, status=status.HTTP_202_ACCEPTED) - logger.debug("Location: %s" % nsHealService.occ_id) - response["Location"] = NS_OCC_BASE_URI % nsHealService.occ_id + logger.debug("Location: %s" % ns_heal_service.occ_id) + response["Location"] = NS_OCC_BASE_URI % ns_heal_service.occ_id logger.debug("Leave NSHealView") return response diff --git a/lcm/pub/enum.py b/lcm/pub/enum.py index 0a667a51..40fcdc37 100644 --- a/lcm/pub/enum.py +++ b/lcm/pub/enum.py @@ -30,9 +30,10 @@ JOB_TYPE = enum( HEAL_VNF="heal vnf", GRANT_VNF="grant vnf", MANUAL_SCALE_VNF="manual scale vnf", - TERMINATE_NS="terminate ns", TERMINATE_VNF="terminate vnf", - UPDATE_NS="update ns" + TERMINATE_NS="terminate ns", + UPDATE_NS="update ns", + HEAL_NS='heal ns' ) JOB_PROGRESS = enum( ERROR=255, |