+ self.assertEqual("down", node["crunch_worker_state"])
+
+ @mock.patch("subprocess.check_output")
+ def test_update_from_sinfo(self, sinfo_mock):
+ sinfo_mock.return_value = "compute99 alloc"
+ node = testutil.arvados_node_mock()
+ self.build_monitor([{
+ 'items': [node],
+ 'items_available': 1,
+ 'offset': 0
+ }, {
+ 'items': [],
+ 'items_available': 1,
+ 'offset': 1
+ }])
+ self.monitor.subscribe_to(node['uuid'],
+ self.subscriber).get(self.TIMEOUT)
+ self.stop_proxy(self.monitor)
+ self.subscriber.assert_called_with(node)
+ self.assertEqual("busy", node["crunch_worker_state"])