Code Review
/
pti
/
o2.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Add o2dms api endpoint
[pti/o2.git]
/
o2ims
/
service
/
watcher
/
pserver_cpu_watcher.py
diff --git
a/o2ims/service/watcher/pserver_cpu_watcher.py
b/o2ims/service/watcher/pserver_cpu_watcher.py
index
e99cdc0
..
66f2294
100644
(file)
--- a/
o2ims/service/watcher/pserver_cpu_watcher.py
+++ b/
o2ims/service/watcher/pserver_cpu_watcher.py
@@
-12,25
+12,30
@@
# See the License for the specific language governing permissions and
\r
# limitations under the License.
\r
\r
# See the License for the specific language governing permissions and
\r
# limitations under the License.
\r
\r
+from o2ims.domain.stx_object import StxGenericModel
\r
from o2ims.service.client.base_client import BaseClient
\r
from o2ims.service.client.base_client import BaseClient
\r
-from o2ims.service.unit_of_work import AbstractUnitOfWork
\r
+
#
from o2ims.service.unit_of_work import AbstractUnitOfWork
\r
from o2ims.service.watcher.resource_watcher import ResourceWatcher
\r
from o2ims.service.watcher.resource_watcher import ResourceWatcher
\r
+from o2ims.domain import commands
\r
+from o2ims.service.messagebus import MessageBus
\r
\r
\r
-
import
logging
\r
-logger =
logging.getL
ogger(__name__)
\r
+
from o2common.helper import o2
logging
\r
+logger =
o2logging.get_l
ogger(__name__)
\r
\r
\r
class PServerCpuWatcher(ResourceWatcher):
\r
def __init__(self, client: BaseClient,
\r
\r
\r
class PServerCpuWatcher(ResourceWatcher):
\r
def __init__(self, client: BaseClient,
\r
-
uow: AbstractUnitOfWork
) -> None:
\r
- super().__init__(client,
uow
)
\r
+
bus: MessageBus
) -> None:
\r
+ super().__init__(client,
bus
)
\r
\r
def _targetname(self):
\r
return "pserver_cpu"
\r
\r
\r
def _targetname(self):
\r
return "pserver_cpu"
\r
\r
- def _probe(self, parent:
object = None
):
\r
- hostid = parent.id
if parent else None
\r
+ def _probe(self, parent:
StxGenericModel
):
\r
+ hostid = parent.id
\r
newmodels = self._client.list(hostid=hostid)
\r
newmodels = self._client.list(hostid=hostid)
\r
- for newmodel in newmodels:
\r
- super()._compare_and_update(newmodel)
\r
- return newmodels
\r
+ # for newmodel in newmodels:
\r
+ # super()._compare_and_update(newmodel)
\r
+ # return newmodels
\r
+ return [commands.UpdatePserverCpu(data=m, parentid=hostid)
\r
+ for m in newmodels]
\r