| /external/autotest/venv/lucifer/ |
| handoffs.py | 43 def clean_up(job_ids):
49 if not job_ids:
52 logger.info('Cleaning up failed jobs: %r', job_ids)
53 hqes = models.HostQueueEntry.objects.filter(job_id__in=job_ids)
88 def mark_complete(job_ids):
90 if not job_ids:
93 logger.info('Marking job handoffs complete: %r', job_ids)
95 .filter(job_id__in=job_ids)
|
| /external/autotest/venv/lucifer/cmd/ |
| job_aborter.py | 99 job_ids = []
104 job_ids.append(handoff.job_id)
105 handoffs.clean_up(job_ids)
106 handoffs.mark_complete(job_ids)
107 metrics.send_expired_jobs(len(job_ids))
|
| /external/autotest/scheduler/shard/ |
| 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]))
|
| shard_client.py | 174 job_ids = [j['id'] for j in jobs_serialized]
175 logging.info('Heartbeat response contains jobs %s', job_ids)
191 id__in=job_ids, hostqueueentry__complete=True)
239 job_ids = list(models.Job.objects.filter(
243 for job_to_upload in models.Job.objects.filter(pk__in=job_ids).all():
248 def _mark_jobs_as_uploaded(self, job_ids):
250 # But then job_ids is empty, so this is harmless.
252 models.Job.objects.filter(pk__in=job_ids).update(shard=self.shard)
278 job_ids = list(models.Job.objects.filter(
286 return job_ids, host_ids, host_statuse
[all...] |
| /external/autotest/scheduler/ |
| query_managers.py | 271 def _get_job_acl_groups(self, job_ids):
280 return self._get_many2many_dict(query, job_ids)
283 def _get_job_ineligible_hosts(self, job_ids):
289 return self._get_many2many_dict(query, job_ids)
293 def _get_job_dependencies(self, job_ids):
299 return self._get_many2many_dict(query, job_ids)
|
| 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])
|
| monitor_db_unittest.py | 229 def _convert_jobs_to_metahosts(self, *job_ids):
230 sql_tuple = '(' + ','.join(str(i) for i in job_ids) + ')'
[all...] |
| /external/autotest/site_utils/ |
| dump_suite_report.py | 22 parser.add_argument('job_ids', type=int, nargs='+',
48 for suite_job_id in options.job_ids:
|
| test_push.py | 385 job_ids = [job.id for job in
388 for job_id in job_ids]
|
| /external/autotest/frontend/afe/ |
| models.py | [all...] |
| rpc_interface.py | 740 job_ids = list(models.Job.objects.filter(
745 if not job_ids:
749 afe_job_id__in=job_ids).exclude(
[all...] |
| /external/autotest/cli/ |
| job.py | 32 msg_items = '<job_ids>'
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/perfetto/infra/perfetto-ci.appspot.com/static/ |
| script.js | 79 for (const jobId of resp.branch.job_ids)
|
| /external/autotest/contrib/ |
| 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/ |
| suite.py | [all...] |
