Lines Matching refs:queue_entry

365     for queue_entry in host_queue_entries:
366         key = _execution_key_for(queue_entry)
370     for queue_entry in host_queue_entries:
371         if not queue_entry.execution_subdir:
373         execution_count = count_per_execution[_execution_key_for(queue_entry)]
374         if execution_count < queue_entry.job.synch_count:
378                       % (queue_entry.job.id, queue_entry.execution_subdir,
379                          execution_count, queue_entry.job.synch_count)})
456     for queue_entry in queue_entries:
457         if (queue_entry.host and (preserve_metahosts or
458                                   not queue_entry.meta_host)):
459             if queue_entry.deleted:
461             if queue_entry.host.invalid:
462                 one_time_hosts.append(queue_entry.host)
464                 hosts.append(queue_entry.host)
465         elif queue_entry.meta_host:
466             meta_hosts.append(queue_entry.meta_host)
625 def _queue_entry_to_dict(queue_entry):  argument
626     job_dict = queue_entry['job']
629                                                queue_entry['execution_subdir'])
630     return _common_entry_to_dict(queue_entry, 'Job', job_dict, exec_path,
631             queue_entry['status'], queue_entry['started_on'])
682             for queue_entry in queue_entries[hqe_index:]:
683                 if queue_entry['started_on'] is None:
686                         queue_entry['started_on'])
690                 next_job_id = queue_entry['job']['id']
696             for queue_entry in queue_entries[hqe_index:]:
697                 if queue_entry['job']['id'] < next_job_id:
717     for queue_entry in queue_entries:
718         interleaved_entries.append(queue_entry)
721             if task['next_job_id'] < queue_entry['job']['id']: