Index

A

admitted (stagegate.TaskCountsSnapshot attribute)

argv (stagegate.TerminatedError attribute) available (stagegate.ResourceSnapshot attribute)

C

cancel() (stagegate.PipelineHandle method) (stagegate.TaskHandle method) cancelled (stagegate.PipelineCountsSnapshot attribute) (stagegate.TaskCountsSnapshot attribute) cancelled() (stagegate.PipelineHandle method) (stagegate.TaskHandle method)

CancelledError capacity (stagegate.ResourceSnapshot attribute) close() (stagegate.Scheduler method) closed (stagegate.SchedulerSnapshot attribute) closed() (stagegate.Scheduler method)

D

discard() (stagegate.PipelineHandle method) DiscardedHandleError

done() (stagegate.PipelineHandle method) (stagegate.TaskHandle method)

E

exception() (stagegate.PipelineHandle method) (stagegate.TaskHandle method)

F

failed (stagegate.PipelineCountsSnapshot attribute) (stagegate.TaskCountsSnapshot attribute)

forced_kill (stagegate.TerminatedError attribute)

I

in_use (stagegate.ResourceSnapshot attribute)

L

label (stagegate.ResourceSnapshot attribute)

M

module stagegate

N

name (stagegate.PipelineSnapshot attribute) (stagegate.RunningPipelineSummary attribute)

name() (stagegate.PipelineHandle method) (stagegate.TaskHandle method)

P

pid (stagegate.TerminatedError attribute) Pipeline (class in stagegate) pipeline_id (stagegate.PipelineSnapshot attribute) (stagegate.RunningPipelineSummary attribute)

pipeline_parallelism (stagegate.SchedulerSnapshot attribute) PipelineCountsSnapshot (class in stagegate) PipelineHandle (class in stagegate) pipelines (stagegate.SchedulerSnapshot attribute) PipelineSnapshot (class in stagegate)

Q

queued (stagegate.PipelineCountsSnapshot attribute) (stagegate.TaskCountsSnapshot attribute)

R

request_terminate() (stagegate.TaskHandle method) resources (stagegate.SchedulerSnapshot attribute) ResourceSnapshot (class in stagegate) result() (stagegate.PipelineHandle method) (stagegate.TaskHandle method) returncode (stagegate.TerminatedError attribute) run() (stagegate.Pipeline method) run_pipeline() (stagegate.Scheduler method)

run_shell() (in module stagegate) run_subprocess() (in module stagegate) running (stagegate.PipelineCountsSnapshot attribute) (stagegate.TaskCountsSnapshot attribute) running() (stagegate.PipelineHandle method) (stagegate.TaskHandle method) running_pipelines (stagegate.SchedulerSnapshot attribute) RunningPipelineSummary (class in stagegate)

S

Scheduler (class in stagegate) SchedulerAbortError SchedulerSnapshot (class in stagegate) shutdown() (stagegate.Scheduler method) shutdown_started (stagegate.SchedulerSnapshot attribute) shutdown_started() (stagegate.Scheduler method) snapshot() (stagegate.PipelineHandle method) (stagegate.Scheduler method)

stage_forward() (stagegate.Pipeline method) stage_index (stagegate.PipelineSnapshot attribute) stagegate module state (stagegate.PipelineSnapshot attribute) succeeded (stagegate.PipelineCountsSnapshot attribute) (stagegate.TaskCountsSnapshot attribute)

T

task() (stagegate.Pipeline method) task_parallelism (stagegate.SchedulerSnapshot attribute) TaskCountsSnapshot (class in stagegate) TaskHandle (class in stagegate) tasks (stagegate.PipelineSnapshot attribute) (stagegate.SchedulerSnapshot attribute)

terminate_requested() (in module stagegate) terminate_tracked_subprocesses() (in module stagegate) terminated (stagegate.TaskCountsSnapshot attribute) TerminatedError total (stagegate.PipelineCountsSnapshot attribute) (stagegate.TaskCountsSnapshot attribute)

U

UnknownResourceError

UnschedulableTaskError

W

wait() (stagegate.Pipeline method)

wait_pipelines() (stagegate.Scheduler method)