From 73d550fb553ef164b3c5512370bdf03175c9ca16 Mon Sep 17 00:00:00 2001 From: Gabriel Cuba Date: Mon, 7 Nov 2022 19:28:14 -0500 Subject: [PATCH] Heal: Await heal operation in RO before N2VC part to avoid errors Change-Id: I1d201be817246fe025cfa4fc77bce5b54151e3a8 Signed-off-by: Gabriel Cuba --- osm_lcm/ns.py | 17 +++++++++++------ 1 file changed, 11 insertions(+), 6 deletions(-) diff --git a/osm_lcm/ns.py b/osm_lcm/ns.py index 61899bb..0b69062 100644 --- a/osm_lcm/ns.py +++ b/osm_lcm/ns.py @@ -7523,17 +7523,22 @@ class NsLcm(LcmBase): self.update_db_2("nsrs", nsr_id, db_nsr_update) step = "Sending heal order to VIM" - task_ro = asyncio.ensure_future( - self.heal_RO( + #task_ro = asyncio.ensure_future( + # self.heal_RO( + # logging_text=logging_text, + # nsr_id=nsr_id, + # db_nslcmop=db_nslcmop, + # stage=stage, + # ) + #) + #self.lcm_tasks.register("ns", nsr_id, nslcmop_id, "heal_RO", task_ro) + #tasks_dict_info[task_ro] = "Healing at VIM" + await self.heal_RO( logging_text=logging_text, nsr_id=nsr_id, db_nslcmop=db_nslcmop, stage=stage, ) - ) - self.lcm_tasks.register("ns", nsr_id, nslcmop_id, "heal_RO", task_ro) - tasks_dict_info[task_ro] = "Healing at VIM" - # VCA tasks # read from db: nsd stage[1] = "Getting nsd={} from db.".format(db_nsr["nsd-id"]) -- 2.25.1