X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FLCM.git;a=blobdiff_plain;f=osm_lcm%2Flcm.py;h=10156d317c1f5715e0d8d9284e34e605a44366b2;hp=e15df9f8a8b58636e18b292484f3d12f3c27cb4d;hb=1b383966afb1f26ddf2def5907df87b2c4724f64;hpb=a95a6cd58d3806648d14a1a3995a5a3d55751e5a

diff --git a/osm_lcm/lcm.py b/osm_lcm/lcm.py
index e15df9f..10156d3 100644
--- a/osm_lcm/lcm.py
+++ b/osm_lcm/lcm.py
@@ -286,6 +286,10 @@ class Lcm:
                 except Exception as e:
                     self.logger.error("Cannot write into '{}' for healthcheck: {}".format(health_check_file, e))
             return
+        elif topic == "pla":
+            if command == "placement":
+                self.ns.update_nsrs_with_pla_result(params)
+            return
         elif topic == "k8scluster":
             if command == "create" or command == "created":
                 k8scluster_id = params.get("_id")
@@ -463,7 +467,7 @@ class Lcm:
         self.first_start = True
         while self.consecutive_errors < 10:
             try:
-                topics = ("ns", "vim_account", "wim_account", "sdn", "nsi", "k8scluster", "k8srepo")
+                topics = ("ns", "vim_account", "wim_account", "sdn", "nsi", "k8scluster", "k8srepo", "pla")
                 topics_admin = ("admin", )
                 await asyncio.gather(
                     self.msg.aioread(topics, self.loop, self.kafka_read_callback),