Searched refs:job_ids (Results 1 – 13 of 13) sorted by relevance
| /external/autotest/scheduler/shard/ |
| D | shard_client.py | 173 job_ids = [j['id'] for j in jobs_serialized]
174 logging.info('Heartbeat response contains jobs %s', job_ids)
190 id__in=job_ids, hostqueueentry__complete=True)
238 job_ids = list(models.Job.objects.filter(
242 for job_to_upload in models.Job.objects.filter(pk__in=job_ids).all():
247 def _mark_jobs_as_uploaded(self, job_ids): argument
251 models.Job.objects.filter(pk__in=job_ids).update(shard=self.shard)
277 job_ids = list(models.Job.objects.filter(
285 return job_ids, host_ids, host_statuses
|
| D | shard_client_integration_tests.py | 51 job_ids, host_ids, _ = client._get_known_jobs_and_hosts()
52 assert(job_ids == [])
92 job_ids, host_ids, _ = client._get_known_jobs_and_hosts()
93 assert(set(job_ids) == set([job.id]))
|
| /external/autotest/scheduler/ |
| D | query_managers.py | 271 def _get_job_acl_groups(self, job_ids): argument
280 return self._get_many2many_dict(query, job_ids)
283 def _get_job_ineligible_hosts(self, job_ids): argument
289 return self._get_many2many_dict(query, job_ids)
293 def _get_job_dependencies(self, job_ids): argument
299 return self._get_many2many_dict(query, job_ids)
|
| D | agent_task.py | 443 job_ids = hqes.values_list('job', flat=True).distinct()
444 assert job_ids.count() == 1, ("AgentTask's queue entries "
447 job = models.Job.objects.get(id=job_ids[0])
|
| D | monitor_db_unittest.py | 229 def _convert_jobs_to_metahosts(self, *job_ids): argument
230 sql_tuple = '(' + ','.join(str(i) for i in job_ids) + ')'
|
| /external/autotest/frontend/afe/ |
| D | models.py | 1112 def get_status_counts(self, job_ids): argument
1117 if not job_ids:
1119 id_list = '(%s)' % ','.join(str(job_id) for job_id in job_ids)
1127 all_job_counts = dict((job_id, {}) for job_id in job_ids)
1443 job_ids = set([])
1458 job_ids |= set([j.id for j in query])
1460 if job_ids:
1464 'candidates': ','.join([str(i) for i in job_ids])})
1465 job_ids -= set([j.id for j in query])
1467 if job_ids:
[all …]
|
| D | rpc_interface.py | 584 job_ids = list(models.Job.objects.filter(
589 if not job_ids:
593 afe_job_id__in=job_ids).exclude(
|
| /external/autotest/cli/ |
| D | job.py | 70 job_ids = []
76 job_ids.append(job_id)
79 return (job_ids, job_names)
91 (job_ids, job_names) = self.__split_jobs_between_ids_names()
93 for items, tag in [(job_ids, tag_id),
|
| /external/autotest/frontend/tko/ |
| D | rpc_interface.py | 137 job_ids = set()
143 job_ids.add(job_id)
147 return list(job_ids)
|
| /external/autotest/site_utils/ |
| D | dump_suite_report.py | 48 for suite_job_id in options.job_ids:
|
| D | test_push.py | 377 job_ids = [job.id for job in
380 for job_id in job_ids]
|
| /external/autotest/contrib/ |
| D | compare_suite.py | 326 job_ids = [int(id) for id in args.jobs.split(',')] variable
330 models.Job.objects.filter(id__in=job_ids)]
338 for job_id in job_ids:
|
| /external/autotest/server/cros/dynamic_suite/ |
| D | suite.py | 1414 job_ids = [job.id for job in self._jobs]
1415 self._afe.run('abort_host_queue_entries', job__id__in=job_ids)
|