Lines Matching refs:hqes
48 jobs=upload_jobs, hqes=upload_hqes,
59 hosts=[], hqes=[],
80 expected_hqes = [(hqe.id) for hqe in hqes]
161 jobs=[job1], hosts=[host1], hqes=job1.hostqueueentry_set.all())
165 jobs=[job2], hosts=[host2], hqes=job2.hostqueueentry_set.all())
180 hqes=job1.hostqueueentry_set.all(), hosts=[host1])
185 jobs=[job1], hqes=job1.hostqueueentry_set.all(), hosts=[])
203 jobs=[job2], hqes=job2.hostqueueentry_set.all())
219 hqes=job2.hostqueueentry_set.all())
1032 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1034 self.assertEquals(len(hqes), 3)
1036 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1038 self.assertEquals(len(hqes), 2)
1040 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1042 self.assertEquals(len(hqes), 1)
1044 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1046 self.assertEquals(len(hqes), 1)
1048 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1050 self.assertEquals(len(hqes), 2)
1052 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1054 self.assertEquals(len(hqes), 3)
1064 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1066 self.assertEquals(len(hqes), 1)
1070 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1073 self.assertEquals(len(hqes), 1)
1079 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1082 self.assertEquals(len(hqes), 1)
1085 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1088 self.assertEquals(len(hqes), 1)
1643 self, jobs, hqes, shard_hostname='host1',
1665 upload_jobs=jobs, upload_hqes=hqes)
1671 upload_jobs=jobs, upload_hqes=hqes)
1676 jobs, hqes = self._get_records_for_sending_to_master()
1677 hqes[0]['status'] = 'Completed'
1679 jobs=jobs, hqes=hqes, exception_to_throw=None)
1688 jobs, hqes = self._get_records_for_sending_to_master()
1689 hqes[0]['status'] = 'Completed'
1691 jobs=jobs, hqes=hqes, exception_to_throw=None, aborted=True)
1741 jobs, hqes = self._get_records_for_sending_to_master()
1745 jobs=jobs, hqes=hqes)
