1331     def get_status_counts(self, job_ids):  argument
1336         if not job_ids:
1338         id_list = '(%s)' % ','.join(str(job_id) for job_id in job_ids)
1346         all_job_counts = dict((job_id, {}) for job_id in job_ids)
1661             job_ids = cls._get_new_jobs_for_shard(shard, known_ids)
1662         if not job_ids:
1664         cls._assign_jobs_to_shard(job_ids, shard)
1665         return cls._jobs_with_ids(job_ids)
1683     def _assign_jobs_to_shard(cls, job_ids, shard):  argument
1684         Job.objects.filter(pk__in=job_ids).update(shard=shard)
1688     def _jobs_with_ids(cls, job_ids):  argument
1689         return list(Job.objects.filter(pk__in=job_ids).all())
1694         job_ids = cls._get_jobs_without_hosts(shard, known_ids)
1695         job_ids |= cls._get_jobs_with_hosts(shard, known_ids)
1696         if job_ids:
1697             job_ids -= cls._filter_finished_jobs(job_ids)
1698         return job_ids
1702     def _filter_finished_jobs(cls, job_ids):  argument
1705                 {'candidates': ','.join([str(i) for i in job_ids])})
1721         job_ids = set([])
1732             job_ids |= set([j.id for j in query])
1741             job_ids |= set([j.id for j in query])
1742         return job_ids