X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/ae8aaa4c55762222c837fcce8e9ad6800ff8b128..f7a665dcd8dfe96b49e63f3caa352f5e5f8b19a1:/services/nodemanager/tests/test_daemon.py diff --git a/services/nodemanager/tests/test_daemon.py b/services/nodemanager/tests/test_daemon.py index e49fc39eed..04ff9b6d79 100644 --- a/services/nodemanager/tests/test_daemon.py +++ b/services/nodemanager/tests/test_daemon.py @@ -9,9 +9,11 @@ import mock import pykka import arvnodeman.daemon as nmdaemon +import arvnodeman.status as status from arvnodeman.jobqueue import ServerCalculator from arvnodeman.computenode.dispatch import ComputeNodeMonitorActor from . import testutil +from . import test_status import logging class NodeManagerDaemonActorTestCase(testutil.ActorTestMixin, @@ -355,10 +357,16 @@ class NodeManagerDaemonActorTestCase(testutil.ActorTestMixin, monitor = self.monitor_list()[0].proxy() self.daemon.update_server_wishlist([]) self.daemon.node_can_shutdown(monitor).get(self.TIMEOUT) + self.daemon.update_server_wishlist([]).get(self.TIMEOUT) self.stop_proxy(self.daemon) self.assertTrue(self.node_shutdown.start.called, "daemon did not shut down booted node on offer") + with test_status.TestServer() as srv: + self.assertEqual(0, srv.get_status().get('nodes_unpaired', None)) + self.assertEqual(1, srv.get_status().get('nodes_shutdown', None)) + self.assertEqual(0, srv.get_status().get('nodes_wish', None)) + def test_booted_node_lifecycle(self): cloud_node = testutil.cloud_node_mock(6) setup = self.start_node_boot(cloud_node, id_num=6)