• Home
  • Raw
  • Download

Lines Matching refs:hqes

355         hqes = rpc_interface.get_host_queue_entries_by_insert_time(
357 self.assertEquals(len(hqes), 3)
359 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
361 self.assertEquals(len(hqes), 2)
363 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
365 self.assertEquals(len(hqes), 1)
367 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
369 self.assertEquals(len(hqes), 1)
371 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
373 self.assertEquals(len(hqes), 2)
375 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
377 self.assertEquals(len(hqes), 3)
387 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
389 self.assertEquals(len(hqes), 1)
393 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
396 self.assertEquals(len(hqes), 1)
402 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
405 self.assertEquals(len(hqes), 1)
408 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
411 self.assertEquals(len(hqes), 1)
1025 jobs=upload_jobs, hqes=upload_hqes,
1036 hosts=[], hqes=[], argument
1057 expected_hqes = [(hqe.id) for hqe in hqes]
1065 self, jobs, hqes, shard_hostname='host1', argument
1087 upload_jobs=jobs, upload_hqes=hqes)
1093 upload_jobs=jobs, upload_hqes=hqes)
1098 jobs, hqes = self._get_records_for_sending_to_master()
1099 hqes[0]['status'] = 'Completed'
1101 jobs=jobs, hqes=hqes, exception_to_throw=None)
1110 jobs, hqes = self._get_records_for_sending_to_master()
1111 hqes[0]['status'] = 'Completed'
1113 jobs=jobs, hqes=hqes, exception_to_throw=None, aborted=True)
1163 jobs, hqes = self._get_records_for_sending_to_master()
1167 jobs=jobs, hqes=hqes)
1295 jobs=[job1], hosts=[host1], hqes=job1.hostqueueentry_set.all())
1299 jobs=[job2], hosts=[host2], hqes=job2.hostqueueentry_set.all())
1316 hqes=job1.hostqueueentry_set.all(), hosts=[host1])
1321 jobs=[job1], hqes=job1.hostqueueentry_set.all(), hosts=[])
1339 jobs=[job2], hqes=job2.hostqueueentry_set.all())
1355 hqes=job2.hostqueueentry_set.all())