| /external/autotest/venv/lucifer/ |
| D | handoffs.py | 43 def clean_up(job_ids): argument
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): argument
90 if not job_ids:
93 logger.info('Marking job handoffs complete: %r', job_ids)
95 .filter(job_id__in=job_ids)
|
| /external/autotest/server/site_tests/moblab_StorageQual/ |
| D | moblab_StorageQual.py | 125 job_ids = self._get_job_ids_from_suite_output(result.stderr)
127 logging.debug('Suite job ids %s', job_ids)
129 keyvals_per_host = self._get_keyval_files_per_host(host, job_ids)
201 job_ids = set()
208 job_ids.add(int(match.groups()[0]))
209 return job_ids
211 def _get_keyval_files_per_host(self, host, job_ids): argument
231 if int(job_id) not in job_ids:
|
| /external/autotest/site_utils/ |
| D | dump_suite_report.py | 52 job_ids = set(options.job_ids)
54 job_ids.add(options.provision_job_id)
58 for suite_job_id in job_ids:
|
| D | test_push.py | 310 job_ids = [job.id for job in
313 for job_id in job_ids]
|
| /external/autotest/venv/lucifer/cmd/ |
| D | job_aborter.py | 98 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/ |
| D | shard_client.py | 187 job_ids = [j['id'] for j in jobs_serialized]
188 logging.info('Heartbeat response contains jobs %s', job_ids)
204 id__in=job_ids, hostqueueentry__complete=True)
256 job_ids = list(models.Job.objects.filter(
260 for job_to_upload in models.Job.objects.filter(pk__in=job_ids).all():
265 def _mark_jobs_as_uploaded(self, job_ids): argument
269 models.Job.objects.filter(pk__in=job_ids).update(shard=self.shard)
296 job_ids = list(jobs.values_list('id', flat=True))
305 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 | 230 def _convert_jobs_to_metahosts(self, *job_ids): argument
231 sql_tuple = '(' + ','.join(str(i) for i in job_ids) + ')'
|
| /external/autotest/frontend/afe/ |
| D | models.py | 1327 def get_status_counts(self, job_ids): argument
1332 if not job_ids:
1334 id_list = '(%s)' % ','.join(str(job_id) for job_id in job_ids)
1342 all_job_counts = dict((job_id, {}) for job_id in job_ids)
1663 job_ids = set([])
1686 job_ids = set([j.id for j in Job.objects.raw(raw_sql)])
1693 job_ids = set([j.id for j in Job.objects.raw(raw_sql)])
1704 job_ids |= set([j.id for j in query])
1713 job_ids |= set([j.id for j in query])
1715 if job_ids:
[all …]
|
| D | rpc_interface.py | 736 job_ids = list(models.Job.objects.filter(
741 if not job_ids:
745 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/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/perfetto/infra/perfetto-ci.appspot.com/static/ |
| D | script.js | 79 for (const jobId of resp.branch.job_ids)
|
| /external/autotest/server/cros/dynamic_suite/ |
| D | suite.py | 1275 job_ids = [job.id for job in self._jobs]
1276 self._afe.run('abort_host_queue_entries', job__id__in=job_ids)
|