Lines Matching full:queue_entry
358 for queue_entry in host_queue_entries:
359 key = _execution_key_for(queue_entry)
363 for queue_entry in host_queue_entries:
364 if not queue_entry.execution_subdir:
366 execution_count = count_per_execution[_execution_key_for(queue_entry)]
367 if execution_count < queue_entry.job.synch_count:
371 % (queue_entry.job.id, queue_entry.execution_subdir,
372 execution_count, queue_entry.job.synch_count)})
519 for queue_entry in queue_entries:
520 if (queue_entry.host and (preserve_metahosts or
521 not queue_entry.meta_host)):
522 if queue_entry.deleted:
524 if queue_entry.host.invalid:
525 one_time_hosts.append(queue_entry.host)
527 hosts.append(queue_entry.host)
528 elif queue_entry.meta_host:
529 meta_hosts.append(queue_entry.meta_host)
534 if queue_entry.atomic_group is not None:
535 atomic_group = queue_entry.atomic_group
537 assert atomic_group.name == queue_entry.atomic_group.name, (
540 id, atomic_group.name, queue_entry.atomic_group.name))
716 if task['queue_entry']:
719 if task['queue_entry']['id'] == qentry['id']:
724 job = models.Job.objects.get(id=task['queue_entry']['job'])
736 def _queue_entry_to_dict(queue_entry):
737 job_dict = queue_entry['job']
740 queue_entry['execution_subdir'])
741 return _common_entry_to_dict(queue_entry, 'Job', job_dict, exec_path,
742 queue_entry['status'], queue_entry['started_on'])
790 if task['queue_entry']:
791 next_job_id = task['queue_entry']['job']
793 for queue_entry in queue_entries[hqe_index:]:
794 if queue_entry['started_on'] is None:
797 queue_entry['started_on'])
801 next_job_id = queue_entry['job']['id']
807 for queue_entry in queue_entries[hqe_index:]:
808 if queue_entry['job']['id'] < next_job_id:
828 for queue_entry in queue_entries:
829 interleaved_entries.append(queue_entry)
832 if task['next_job_id'] < queue_entry['job']['id']:
