Lines Matching refs:HostQueueEntry
268 @param queue_entry - A HostQueueEntry object - If supplied and no Job
523 statuses = (models.HostQueueEntry.Status.STARTING,
524 models.HostQueueEntry.Status.RUNNING,
525 models.HostQueueEntry.Status.GATHERING,
526 models.HostQueueEntry.Status.PARSING,
527 models.HostQueueEntry.Status.ARCHIVING)
529 queue_entries = scheduler_models.HostQueueEntry.fetch(
565 Construct an AgentTask instance for the given active HostQueueEntry.
567 @param queue_entry: a HostQueueEntry
573 if queue_entry.status in (models.HostQueueEntry.Status.STARTING,
574 models.HostQueueEntry.Status.RUNNING):
578 if queue_entry.status == models.HostQueueEntry.Status.GATHERING:
580 if queue_entry.status == models.HostQueueEntry.Status.PARSING:
582 if queue_entry.status == models.HostQueueEntry.Status.ARCHIVING:
591 non_host_statuses = (models.HostQueueEntry.Status.PARSING,
592 models.HostQueueEntry.Status.ARCHIVING)
602 @param entry: a HostQueueEntry or a SpecialTask
622 creates a HostQueueEntry and saves it as it's queue_entry.
661 for entry in scheduler_models.HostQueueEntry.fetch(where="status = '%s'"
686 models.HostQueueEntry.Status.PENDING):
692 queue_entries = scheduler_models.HostQueueEntry.fetch(
693 where='status = "%s"' % models.HostQueueEntry.Status.VERIFYING)
805 queue_entry.set_status(models.HostQueueEntry.Status.STARTING)
918 for entry in scheduler_models.HostQueueEntry.fetch(
1110 queue_entry_ids - A sequence of HostQueueEntry ids this task handles.
1211 queue_entry.set_status(models.HostQueueEntry.Status.RUNNING)
1295 allowed_hqe_statuses=(models.HostQueueEntry.Status.STARTING,
1296 models.HostQueueEntry.Status.RUNNING),
1312 queue_entry.set_status(models.HostQueueEntry.Status.GATHERING)
1357 if hqe.status != models.HostQueueEntry.Status.STARTING:
1358 hqe.set_status(models.HostQueueEntry.Status.PARSING)
