Home
last modified time | relevance | path

Searched refs:_job (Results 1 – 17 of 17) sorted by relevance

/external/autotest/site_utils/sponge_lib/
Dautotest_job_info.py33 self._job = job
35 self.create_task_info(test) for test in self._job.tests)
44 return job_directories.get_job_id_or_task_id(self._job.dir)
49 return self._job.label
54 return self._job.user
59 return self._job.keyval_dict.get('job_started', time.time())
64 return self._job.keyval_dict.get('job_finished', time.time())
69 return self._job.machine
74 return self._job.keyval_dict.get('drone', socket.gethostname())
79 return self._job.keyval_dict
[all …]
Dacts_job_info.py130 return self._job.user.strip("'").strip('"')
/external/autotest/venv/lucifer/
Dhandlers.py45 self._job = job
66 self._job.hostqueueentry_set.all().update(
72 self._job.hostqueueentry_set.all().update(
77 self._job.hostqueueentry_set.all().update(
81 for hqe in self._job.hostqueueentry_set.all().prefetch_related('host'):
83 jobx.write_aborted_keyvals_and_status(self._job, self._results_dir)
118 requested_by=models.User.objects.get(login=self._job.owner))
126 requested_by=models.User.objects.get(login=self._job.owner))
134 reset_after_failure = not self._job.run_reset and not success
135 hqes = self._job.hostqueueentry_set.all().prefetch_related('host')
[all …]
/external/autotest/site_utils/
Dgs_offloader_unittest.py550 self._job = self.make_job(self.REGULAR_JOBLIST[0])
605 self._job.queue_args[0],
606 self._job.queue_args[1],
607 self._job.queue_args[2])
610 os.path.isdir(self._job.queue_args[0]))
616 self._job.queue_args)
625 self._job.queue_args)
926 self._job = self.make_job(self.REGULAR_JOBLIST[0])
937 self.assertEqual(self._job.offload_count, 0)
938 self.assertEqual(self._job.first_offload_start, 0)
[all …]
/external/autotest/server/site_tests/tast/
Dtast_unittest.py55 self._job = FakeServerJob(make_subdir('job'), make_subdir('tmp'))
61 self._test = tast.tast(self._job, self._bin_dir, self._out_dir)
179 if self._job.post_run_hook:
180 self._job.post_run_hook()
200 if not os.path.exists(os.path.join(self._job.resultdir,
203 return utils.read_keyval(self._job.resultdir)
213 status_string(self._job.status_entries))
224 status_string(self._job.status_entries))
233 status_string(self._job.status_entries))
242 status_string(self._job.status_entries))
[all …]
/external/python/cpython2/Lib/multiprocessing/
Dpool.py262 self._taskqueue.put((((result._job, i, func, (x,), {})
269 self._taskqueue.put((((result._job, i, mapstar, (x,), {})
280 self._taskqueue.put((((result._job, i, func, (x,), {})
287 self._taskqueue.put((((result._job, i, mapstar, (x,), {})
297 self._taskqueue.put(([(result._job, None, func, args, kwds)], None))
317 self._taskqueue.put((((result._job, i, mapstar, (x,), {})
544 self._job = job_counter.next()
548 cache[self._job] = self
584 del self._cache[self._job]
602 del cache[self._job]
[all …]
/external/python/cpython3/Lib/multiprocessing/
Dpool.py307 self._guarded_task_generation(result._job, func, iterable),
320 self._guarded_task_generation(result._job,
337 self._guarded_task_generation(result._job, func, iterable),
349 self._guarded_task_generation(result._job,
364 self._taskqueue.put(([(result._job, 0, func, args, kwds)], None))
397 self._guarded_task_generation(result._job,
633 self._job = next(job_counter)
637 cache[self._job] = self
666 del self._cache[self._job]
685 del cache[self._job]
[all …]
/external/toolchain-utils/automation/server/monitor/
Ddashboard.py41 self._job = pickle.loads(GetServerConnection().GetJob(job_id))
44 job = self._job
72 for evlog in self._job.timeline.GetTransitionEventHistory()]
75 log_path = os.path.join(self._job.logs_dir,
76 '%s.gz' % self._job.log_filename_prefix)
/external/tensorflow/tensorflow/python/framework/
Ddevice.py93 self._job = None
101 return self._job
106 self._job = str(job)
108 self._job = None
/external/grpc-grpc/tools/run_tests/python_utils/
Ddockerjob.py116 self._job = jobset.Job(
130 self._job.suppress_failure_message()
135 return self._job.state() == jobset._RUNNING
/external/autotest/scheduler/
Dpostjob_task.py232 self._job = queue_entries[0].job
271 not self._job.run_reset and (
308 reboot_after = self._job.reboot_after
324 requested_by=self._job.owner_model())
338 requested_by=self._job.owner_model())
/external/grpc-grpc/tools/run_tests/
Drun_performance_tests.py52 self._job = None
56 self._job = jobset.Job(
61 return self._job and self._job.state() == jobset._RUNNING
64 if self._job:
65 self._job.kill()
66 self._job = None
/external/mesa3d/src/intel/vulkan/tests/
Dstate_pool_no_free.c41 static void *alloc_states(void *_job) in alloc_states() argument
43 struct job *job = _job; in alloc_states()
Dblock_pool_no_free.c41 static void *alloc_blocks(void *_job) in alloc_blocks() argument
43 struct job *job = _job; in alloc_blocks()
/external/autotest/client/bin/
Djob.py81 self._job = weakref.proxy(job_) # avoid a circular reference
86 return self._job._record_indent
90 self._job._record_indent += 1
94 self._job._record_indent -= 1
/external/toybox/toys/pending/
Dcrond.c44 typedef struct _job { struct
45 struct _job *next, *prev; argument
/external/autotest/server/
Dserver_job.py185 self._job = job
198 self._hook(self._job, entry)