| /external/autotest/scheduler/ |
| rdb_utils.py | 78 R1 (parent_job_id: 10, need hosts: 2)
79 R2 (parent_job_id: 10, need hosts: 4)
124 (r.parent_job_id, r.suite_min_duts)
125 for r in self.requests_to_counts.iterkeys() if r.parent_job_id)
130 """ Group similar requests, sort by priority and parent_job_id.
140 -request[0].parent_job_id)
151 parent_id = host_request.parent_job_id
|
| host_scheduler.py | 131 parent_id = queue_entry.job.parent_job_id
135 logging.error('HQE (id: %d, parent_job_id: %d, host: %s) '
154 parent_job_id = self.hosts_to_suites.pop(host.id)
155 count = self.suite_host_num[parent_job_id] - 1
157 del self.suite_host_num[parent_job_id]
159 self.suite_host_num[parent_job_id] = count
162 parent_job_id, host.hostname, count)
379 parent_job_ids = set([q.job.parent_job_id
380 for q in host_jobs if q.job.parent_job_id])
|
| rdb_lib.py | 54 parent_id = queue_entry.job.parent_job_id
60 'parent_job_id': queue_entry.job.parent_job_id,
|
| query_managers.py | 83 'parent_job_id, '
191 any suites, and maps the host id to its parent_job_id.
200 parent_job_id = hqe.job.parent_job_id
201 count = suite_host_num.get(parent_job_id, 0)
202 suite_host_num[parent_job_id] = count + 1
203 hosts_to_suites[host_id] = parent_job_id
|
| rdb_testing_utils.py | 36 'priority': 0, 'parent_job_id': 0}
338 def get_request(dep_names, acl_names, priority=0, parent_job_id=0):
343 parent_job_id=parent_job_id)._request
382 priority=0, parent_job_id=None, shard_hostname=None):
405 owner=user, parent_job_id=parent_job_id)
448 """Create num jobs with the same parent_job_id, board, build, priority.
463 parent_job_id=parent_job.id)
|
| rdb_integration_tests.py | 453 # that places it ahead of the earlier suite, if parent_job_id is
461 # because priority trumps parent_job_id and time of creation.
476 if request.parent_job_id is None]):
477 raise ValueError('Parent_job_id can never be None.')
487 key=lambda r: -r.parent_job_id)
496 if request.parent_job_id == 0:
501 if request.parent_job_id == 1:
571 suites[queue_entry.job.parent_job_id][1].append(host)
|
| rdb_cache_unittests.py | 44 acls=test_utils.DEFAULT_ACLS, priority=0, parent_job_id=0, **kwargs):
51 deps, acls, priority, parent_job_id)]
171 default_params['parent_job_id'] = i
309 default_params['parent_job_id'] = i
328 default_params['parent_job_id'] = 1
|
| monitor_db.py | [all...] |
| /external/autotest/frontend/afe/ |
| frontend_test_utils.py | 92 owner='autotest_system', parent_job_id=None,
109 @param parent_job_id - The id of a parent_job. If a job with the id
113 @raises model.DoesNotExist: If parent_job_id is specified but a job with
114 id=parent_job_id does not exist.
128 parent_job = (models.Job.objects.get(id=parent_job_id)
129 if parent_job_id else None)
159 parent_job_id=None):
168 parent_job_id=parent_job_id, **args)
|
| rpc_utils.py | 164 parent_job_id = ('DISTINCT parent_job_id')
167 'WHERE parent_job_id IS NOT NULL)')
170 where.append('id IN ' + filter_common % parent_job_id)
175 'WHERE parent_job_id IS NOT NULL'
176 ' AND (sub_query.parent_job_id=afe_jobs.id'
765 parent_job_id=None,
823 parent_job_id=parent_job_id,
[all...] |
| /external/autotest/server/cros/dynamic_suite/ |
| fakes.py | 39 def __init__(self, id=0, statuses=[], hostnames=[], parent_job_id=None):
45 self.parent_job_id = parent_job_id
|
| job_status_unittest.py | 110 parent_job_id=54321)
|
| /external/autotest/server/ |
| sequence.py | 159 parent_job_id=current_job_id, test_retry=0, run_reset=False,
|
| server_job.py | 248 parent_job_id=None, host_attributes=None, in_lab=False):
276 @param parent_job_id: Job ID of the parent job. Default to None if the
331 if parent_job_id:
332 job_data['parent_job_id'] = parent_job_id
363 self.parent_job_id = parent_job_id
472 self.parent_job_id)
[all...] |
| autoserv | 177 # --parent_job_id is only useful in autoserv running in host, not in
180 if '--parent_job_id' in args:
181 index = args.index('--parent_job_id')
182 args.remove('--parent_job_id')
460 if parser.options.parent_job_id:
461 kwargs['parent_job_id'] = int(parser.options.parent_job_id)
|
| autoserv.py | 177 # --parent_job_id is only useful in autoserv running in host, not in
180 if '--parent_job_id' in args:
181 index = args.index('--parent_job_id')
182 args.remove('--parent_job_id')
460 if parser.options.parent_job_id:
461 kwargs['parent_job_id'] = int(parser.options.parent_job_id)
|
| /external/autotest/tko/ |
| db.py | 436 def insert_job(self, tag, job, parent_job_id=None, commit=None):
441 @param parent_job_id: The parent job id.
464 'afe_parent_job_id': parent_job_id,
470 if parent_job_id:
471 job.afe_parent_job_id = str(parent_job_id)
|
| /external/autotest/contrib/ |
| find_suite_tasks.py | 79 child_jobs = afe.get_jobs(parent_job_id=suite_job_id)
|
| compare_suite.py | 329 parent_jobs = [job.parent_job_id for job in
341 test_jobs = models.Job.objects.filter(parent_job_id=job_id)
|
| /external/autotest/server/lib/ |
| suite_report.py | 181 child_jobs = afe.get_jobs(parent_job_id=suite_job_id)
|
| /external/autotest/site_utils/ |
| diagnosis_utils.py | 344 parent_job_id=job_id, summary=True,
|
| job_history.py | 350 for job in models.Job.objects.filter(parent_job_id=self.id):
|
| gs_offloader.py | 457 parent_job_id = str(keyval['parent_job_id'])
468 # Path: bucket/build/parent_job_id/cheets_CTS.*/job_id_timestamp/
469 # or bucket/build/parent_job_id/cheets_GTS.*/job_id_timestamp/
471 DEFAULT_CTS_APFE_GSURI, build, parent_job_id,
[all...] |
| run_suite_unittest.py | 155 return return_values[kwargs['parent_job_id']]
253 parent_job_id=suite_job_id)
|
| test_push.py | 386 models.Job.objects.filter(parent_job_id=suite_job_id)]
|
