Lines Matching refs:_job

45         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')
155         reboot_after = self._job.reboot_after
179         for hqe in self._job.hostqueueentry_set.all():
190             _stop_prejob_hqes(self._job)
193         if self._job.shard_id is not None:
195             self._job.shard_id = None
196             self._job.save(update_fields=['shard_id'])
201         if jobx.is_aborted(self._job):