X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_lcm%2Flcm.py;h=273edc18e06e286c0e24592a566f8f583954bdcd;hb=28b0bf87c3fe2bd99cd3d5665eae484df8c3b44c;hp=8932d8910664bdbd86c6e4bc3b07f133d140b6af;hpb=506398326f3d6c95e423ff3b9185a3ffe6a8abe0;p=osm%2FLCM.git diff --git a/osm_lcm/lcm.py b/osm_lcm/lcm.py index 8932d89..273edc1 100644 --- a/osm_lcm/lcm.py +++ b/osm_lcm/lcm.py @@ -460,9 +460,7 @@ class Lcm: nslcmop_id = nslcmop["_id"] nsr_id = nslcmop["nsInstanceId"] task = asyncio.ensure_future(self.ns.heal(nsr_id, nslcmop_id)) - self.lcm_tasks.register( - "ns", nsr_id, nslcmop_id, "ns_heal", task - ) + self.lcm_tasks.register("ns", nsr_id, nslcmop_id, "ns_heal", task) return elif command == "migrate": nslcmop = params @@ -476,9 +474,15 @@ class Lcm: nslcmop_id = nslcmop["_id"] nsr_id = nslcmop["nsInstanceId"] task = asyncio.ensure_future(self.ns.vertical_scale(nsr_id, nslcmop_id)) - self.logger.debug("nsr_id,nslcmop_id,task {},{},{}".format(nsr_id, nslcmop_id, task)) - self.lcm_tasks.register("ns", nsr_id, nslcmop_id, "ns_verticalscale", task) - self.logger.debug("LCM task registered {},{},{} ".format(nsr_id, nslcmop_id, task)) + self.logger.debug( + "nsr_id,nslcmop_id,task {},{},{}".format(nsr_id, nslcmop_id, task) + ) + self.lcm_tasks.register( + "ns", nsr_id, nslcmop_id, "ns_verticalscale", task + ) + self.logger.debug( + "LCM task registered {},{},{} ".format(nsr_id, nslcmop_id, task) + ) return elif command == "show": nsr_id = params