X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_lcm%2Flcm.py;h=273edc18e06e286c0e24592a566f8f583954bdcd;hb=28b0bf87c3fe2bd99cd3d5665eae484df8c3b44c;hp=5f630b23811bcefc6a84aff7cda7212eb1de4bde;hpb=56b86c280d4c67ea0844b2049b4e505abba8429e;p=osm%2FLCM.git diff --git a/osm_lcm/lcm.py b/osm_lcm/lcm.py index 5f630b2..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 @@ -759,7 +763,7 @@ class Lcm: try: # read file as yaml format with open(config_file) as f: - conf = yaml.load(f, Loader=yaml.Loader) + conf = yaml.safe_load(f) # Ensure all sections are not empty for k in ( "global",