| D | rpc_interface_unittest.py | 99 def _testShardHeartbeatFetchHostlessJobHelper(self, host1): argument
106 self._do_heartbeat_and_assert_response(hosts=[host1])
109 def _testShardHeartbeatIncorrectHostsHelper(self, host1): argument
115 self._do_heartbeat_and_assert_response(known_hosts=[host1, host2],
119 def _testShardHeartbeatLabelRemovalRaceHelper(self, shard1, host1, label1): argument
135 known_hosts=[host1], hosts=[], incorrect_host_ids=[host1.id])
140 def _testShardRetrieveJobsHelper(self, shard1, host1, label1, shard2, argument
164 jobs=[job1], hosts=[host1], hqes=job1.hostqueueentry_set.all())
174 known_jobs=[job1], known_hosts=[host1], hosts=[host3])
177 def _testResendJobsAfterFailedHeartbeatHelper(self, shard1, host1, label1): argument
[all …]
|