X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/6d8a27a40903f0dc61876947cecc9401edd3a32c..58ead50fe4b7014562c0697290cf933a956ab852:/services/nodemanager/tests/test_jobqueue.py diff --git a/services/nodemanager/tests/test_jobqueue.py b/services/nodemanager/tests/test_jobqueue.py index 3814ba4610..0a4d136d40 100644 --- a/services/nodemanager/tests/test_jobqueue.py +++ b/services/nodemanager/tests/test_jobqueue.py @@ -14,7 +14,9 @@ class ServerCalculatorTestCase(unittest.TestCase): def calculate(self, servcalc, *constraints): return servcalc.servers_for_queue( - [{'runtime_constraints': cdict} for cdict in constraints]) + [{'uuid': 'zzzzz-jjjjj-{:015x}'.format(index), + 'runtime_constraints': cdict} + for index, cdict in enumerate(constraints)]) def test_empty_queue_needs_no_servers(self): servcalc = self.make_calculator([1]) @@ -63,8 +65,8 @@ class JobQueueMonitorActorTestCase(testutil.RemotePollLoopActorTestMixin, def test_subscribers_get_server_lists(self): self.build_monitor([{'items': [1, 2]}], self.MockCalculator()) - self.monitor.subscribe(self.subscriber) - self.wait_for_call(self.subscriber) + self.monitor.subscribe(self.subscriber).get(self.TIMEOUT) + self.stop_proxy(self.monitor) self.subscriber.assert_called_with([testutil.MockSize(1), testutil.MockSize(2)])