Lines Matching refs:jobs
513 jobs=upload_jobs, hqes=upload_hqes,
523 def _assert_shard_heartbeat_response(self, shard_hostname, retval, jobs=[], argument
529 (job.id, job.name, shard_hostname) for job in jobs]
549 self, jobs, hqes, shard_hostname='host1', argument
569 upload_jobs=jobs, upload_hqes=hqes)
575 upload_jobs=jobs, upload_hqes=hqes)
580 jobs, hqes = self._get_records_for_sending_to_master()
583 jobs=jobs, hqes=hqes, exception_to_throw=None)
592 jobs, hqes = self._get_records_for_sending_to_master()
595 jobs=jobs, hqes=hqes, exception_to_throw=None, aborted=True)
604 jobs, hqes = self._get_records_for_sending_to_master()
607 jobs=jobs, hqes=hqes, shard_hostname='other_shard')
614 jobs=[], hqes=hqes)
619 jobs, hqes = self._get_records_for_sending_to_master()
620 jobs[0]['id'] = 3
623 jobs=jobs, hqes=hqes)
689 jobs=[job1], hosts=[host1], hqes=job1.hostqueueentry_set.all())
693 jobs=[job2], hosts=[host2], hqes=job2.hostqueueentry_set.all())
709 jobs=[job1],
715 jobs=[job1], hqes=job1.hostqueueentry_set.all(), hosts=[])
733 jobs=[job2], hqes=job2.hostqueueentry_set.all())
748 jobs=[job2],