X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2ims%2Fservice%2Fwatcher%2Fpserver_watcher.py;h=8222cc3b38bf0dddd77e6ab470db03f525eababa;hb=44f01a560347914798d8f913696d0e495ee076f8;hp=befc2f6397352e5dbf062afda8dbe901dd115958;hpb=387ee50cfe8e97ba211464c311bb7b6eb9ee2961;p=pti%2Fo2.git diff --git a/o2ims/service/watcher/pserver_watcher.py b/o2ims/service/watcher/pserver_watcher.py index befc2f6..8222cc3 100644 --- a/o2ims/service/watcher/pserver_watcher.py +++ b/o2ims/service/watcher/pserver_watcher.py @@ -13,11 +13,11 @@ # limitations under the License. from o2ims.domain.stx_object import StxGenericModel -from o2ims.service.client.base_client import BaseClient -# from o2ims.service.unit_of_work import AbstractUnitOfWork +from o2common.service.client.base_client import BaseClient +# from o2common.service.unit_of_work import AbstractUnitOfWork from o2ims.service.watcher.resource_watcher import ResourceWatcher from o2ims.domain import commands -from o2ims.service.messagebus import MessageBus +from o2common.service.messagebus import MessageBus from o2common.helper import o2logging logger = o2logging.get_logger(__name__) @@ -34,5 +34,5 @@ class PServerWatcher(ResourceWatcher): def _probe(self, parent: StxGenericModel): resourcepoolid = parent.id newmodels = self._client.list(resourcepoolid=resourcepoolid) - return [commands.UpdatePserverCpu(data=m, parentid=resourcepoolid) + return [commands.UpdatePserver(data=m, parentid=resourcepoolid) for m in newmodels]