Lines Matching refs:hqes
51 jobs=upload_jobs, hqes=upload_hqes,
62 hosts=[], hqes=[], argument
83 expected_hqes = [(hqe.id) for hqe in hqes]
164 jobs=[job1], hosts=[host1], hqes=job1.hostqueueentry_set.all())
168 jobs=[job2], hosts=[host2], hqes=job2.hostqueueentry_set.all())
183 hqes=job1.hostqueueentry_set.all(), hosts=[host1])
188 jobs=[job1], hqes=job1.hostqueueentry_set.all(), hosts=[])
206 jobs=[job2], hqes=job2.hostqueueentry_set.all())
222 hqes=job2.hostqueueentry_set.all())
1023 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1025 self.assertEquals(len(hqes), 3)
1027 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1029 self.assertEquals(len(hqes), 2)
1031 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1033 self.assertEquals(len(hqes), 1)
1035 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1037 self.assertEquals(len(hqes), 1)
1039 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1041 self.assertEquals(len(hqes), 2)
1043 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1045 self.assertEquals(len(hqes), 3)
1055 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1057 self.assertEquals(len(hqes), 1)
1061 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1064 self.assertEquals(len(hqes), 1)
1070 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1073 self.assertEquals(len(hqes), 1)
1076 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
1079 self.assertEquals(len(hqes), 1)
1656 self, jobs, hqes, shard_hostname='host1', argument
1678 upload_jobs=jobs, upload_hqes=hqes)
1684 upload_jobs=jobs, upload_hqes=hqes)
1689 jobs, hqes = self._get_records_for_sending_to_main()
1690 hqes[0]['status'] = 'Completed'
1692 jobs=jobs, hqes=hqes, exception_to_throw=None)
1701 jobs, hqes = self._get_records_for_sending_to_main()
1702 hqes[0]['status'] = 'Completed'
1704 jobs=jobs, hqes=hqes, exception_to_throw=None, aborted=True)
1754 jobs, hqes = self._get_records_for_sending_to_main()
1758 jobs=jobs, hqes=hqes)