X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_lcm%2Fns.py;h=ab224cba153a775b1b28a4e85eca93345fbe6e57;hb=refs%2Fchanges%2F97%2F9597%2F3;hp=fbefc4d12fb9d1d2af4f58dec14469ea20a2d1a4;hpb=aac0cbb7981bb3304b9dc194a9ebedd05b45e1d9;p=osm%2FLCM.git

diff --git a/osm_lcm/ns.py b/osm_lcm/ns.py
index fbefc4d..ab224cb 100644
--- a/osm_lcm/ns.py
+++ b/osm_lcm/ns.py
@@ -2450,6 +2450,22 @@ class NsLcm(LcmBase):
 
                 self.update_db_2("vnfrs", vnfr_data.get("_id"), vnfr_update_dict)
 
+            kdu_config = kdud.get("kdu-configuration")
+            if kdu_config and kdu_config.get("initial-config-primitive") and kdu_config.get("juju") is None:
+                initial_config_primitive_list = kdu_config.get("initial-config-primitive")
+                initial_config_primitive_list.sort(key=lambda val: int(val["seq"]))
+
+                for initial_config_primitive in initial_config_primitive_list:
+                    primitive_params_ = self._map_primitive_params(initial_config_primitive, {}, {})
+
+                    await asyncio.wait_for(
+                        self.k8scluster_map[k8sclustertype].exec_primitive(
+                            cluster_uuid=k8s_instance_info["k8scluster-uuid"],
+                            kdu_instance=kdu_instance,
+                            primitive_name=initial_config_primitive["name"],
+                            params=primitive_params_, db_dict={}),
+                        timeout=timeout)
+
         except Exception as e:
             # Prepare update db with error and raise exception
             try: