X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/92d7a504629d848927d5334b0a801cd3993a585b..d7b6ec65cfd774f0d17c96d2baf9b6620c55ad8d:/services/nodemanager/tests/test_daemon.py diff --git a/services/nodemanager/tests/test_daemon.py b/services/nodemanager/tests/test_daemon.py index 00e05a147f..7da250be26 100644 --- a/services/nodemanager/tests/test_daemon.py +++ b/services/nodemanager/tests/test_daemon.py @@ -522,7 +522,7 @@ class NodeManagerDaemonActorTestCase(testutil.ActorTestMixin, def test_nodes_shutting_down_replaced_below_max_nodes(self): size = testutil.MockSize(6) cloud_node = testutil.cloud_node_mock(6, size=size) - self.make_daemon([cloud_node], [testutil.arvados_node_mock(6)], + self.make_daemon([cloud_node], [testutil.arvados_node_mock(6, crunch_worker_state='down')], avail_sizes=[(size, {"cores":1})]) self.assertEqual(1, self.alive_monitor_count()) monitor = self.monitor_list()[0].proxy() @@ -718,25 +718,3 @@ class NodeManagerDaemonActorTestCase(testutil.ActorTestMixin, # test for that. self.assertEqual(2, sizecounts[small.id]) self.assertEqual(1, sizecounts[big.id]) - - @mock.patch("arvnodeman.daemon.NodeManagerDaemonActor._resume_node") - def test_resume_drained_nodes(self, resume_node): - cloud_node = testutil.cloud_node_mock(1) - arv_node = testutil.arvados_node_mock(1, info={"ec2_instance_id": "1", "slurm_state": "down"}) - self.make_daemon([cloud_node], [arv_node]) - resume_node.assert_called_with(self.daemon.cloud_nodes.get(self.TIMEOUT).nodes.values()[0]) - self.stop_proxy(self.daemon) - - @mock.patch("arvnodeman.daemon.NodeManagerDaemonActor._resume_node") - def test_no_resume_shutdown_nodes(self, resume_node): - cloud_node = testutil.cloud_node_mock(1) - arv_node = testutil.arvados_node_mock(1, info={"ec2_instance_id": "1", "slurm_state": "down"}) - - self.make_daemon([cloud_node], []) - - self.node_shutdown = mock.MagicMock(name='shutdown_mock') - self.daemon.shutdowns.get(self.TIMEOUT)[cloud_node.id] = self.node_shutdown - - self.daemon.update_arvados_nodes([arv_node]).get(self.TIMEOUT) - self.stop_proxy(self.daemon) - resume_node.assert_not_called()