X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2app%2Fentrypoints%2Fresource_watcher.py;h=085fb132829c82dc66df03403e09fab8ecb9f4a1;hb=b2bda65ba534ae72433f914f70384666e369ea0a;hp=2e9e0c0611926dbf8a006adbb479ab7bf137355f;hpb=4aabbc42db31fb781f16eecf59223776cff3b034;p=pti%2Fo2.git

diff --git a/o2app/entrypoints/resource_watcher.py b/o2app/entrypoints/resource_watcher.py
index 2e9e0c0..085fb13 100644
--- a/o2app/entrypoints/resource_watcher.py
+++ b/o2app/entrypoints/resource_watcher.py
@@ -51,6 +51,8 @@ from o2ims.adapter.clients.ocloud_client import StxEthClient
 from o2ims.service.watcher.pserver_acc_watcher import PServerAccWatcher
 from o2ims.adapter.clients.ocloud_client import StxAccClient
 
+from o2ims.adapter.clients.alarm_dict_client import load_alarm_definition,\
+    load_alarm_dictionary_from_conf_file
 from o2ims.service.watcher.agg_compute_watcher import ComputeAggWatcher
 from o2ims.service.watcher.agg_network_watcher import NetworkAggWatcher
 from o2ims.service.watcher.agg_storage_watcher import StorageAggWatcher
@@ -70,6 +72,8 @@ class WatcherService(cotyledon.Service):
         self.args = args
         self.bus = bootstrap.bootstrap()
         self.worker = PollWorker(bus=self.bus)
+        load_alarm_definition(self.bus.uow)
+        load_alarm_dictionary_from_conf_file(self.bus.uow)
 
     def run(self):
         try:
@@ -83,6 +87,8 @@ class WatcherService(cotyledon.Service):
             child_respool = root.addchild(
                 ResourcePoolWatcher(StxResourcePoolClient(),
                                     self.bus))
+
+            # Add Aggregate watch
             child_respool.addchild(
                 ComputeAggWatcher(ComputeAggClient(), self.bus))
             child_respool.addchild(
@@ -92,6 +98,7 @@ class WatcherService(cotyledon.Service):
             child_respool.addchild(
                 UndefinedAggWatcher(UndefinedAggClient(), self.bus))
 
+            # Add Resource watch
             child_pserver = child_respool.addchild(
                 PServerWatcher(StxPserverClient(), self.bus))
             child_pserver.addchild(
@@ -109,11 +116,10 @@ class WatcherService(cotyledon.Service):
             child_pserver.addchild(
                 PServerAccWatcher(StxAccClient(), self.bus))
 
-            self.worker.add_watcher(root)
-
             # Add Alarm watch
-            root = WatcherTree(
+            child_respool.addchild(
                 AlarmWatcher(StxAlarmClient(self.bus.uow), self.bus))
+
             self.worker.add_watcher(root)
 
             self.worker.start()