Index

A

acquire_slot() (dv_flow.mgr.runner_backend.RunnerBackend method) (dv_flow.mgr.runner_backend_local.LocalBackend method)

addTask() (dv_flow.mgr.TaskGenCtxt method)

C

cancel_inflight() (dv_flow.mgr.runner_backend.RunnerBackend method)

create() (dv_flow.mgr.TaskRunCtxt method)

E

error() (dv_flow.mgr.TaskRunCtxt method) exec() (dv_flow.mgr.TaskRunCtxt method) (dv_flow.mgr.uptodate_ctxt.UpToDateCtxt method)

exec_parallel() (dv_flow.mgr.TaskRunCtxt method) execute_task() (dv_flow.mgr.runner_backend.RunnerBackend method) (dv_flow.mgr.runner_backend_local.LocalBackend method)

G

getInputs() (dv_flow.mgr.TaskGenCtxt method)

I

info() (dv_flow.mgr.TaskRunCtxt method)

is_remote (dv_flow.mgr.runner_backend.RunnerBackend property) (dv_flow.mgr.runner_backend_local.LocalBackend property)

L

LocalBackend (class in dv_flow.mgr.runner_backend_local)

M

marker() (dv_flow.mgr.TaskRunCtxt method) mkDataItem() (dv_flow.mgr.TaskRunCtxt method)

mkName() (dv_flow.mgr.TaskGenCtxt method) mkTaskNode() (dv_flow.mgr.TaskGenCtxt method)

P

PyPkg (class in dv_flow.mgr) PyPkg.Params (class in dv_flow.mgr)

PyTask (class in dv_flow.mgr) PyTask.Params (class in dv_flow.mgr)

R

release_slot() (dv_flow.mgr.runner_backend.RunnerBackend method) (dv_flow.mgr.runner_backend_local.LocalBackend method)

run_subgraph() (dv_flow.mgr.TaskRunCtxt method) RunnerBackend (class in dv_flow.mgr.runner_backend)

S

start() (dv_flow.mgr.runner_backend.RunnerBackend method) (dv_flow.mgr.runner_backend_local.LocalBackend method)

stop() (dv_flow.mgr.runner_backend.RunnerBackend method) (dv_flow.mgr.runner_backend_local.LocalBackend method)

T

TaskDataInput (class in dv_flow.mgr) TaskDataItem (class in dv_flow.mgr) TaskDataResult (class in dv_flow.mgr)

TaskGenCtxt (class in dv_flow.mgr) TaskMarker (class in dv_flow.mgr) TaskMarkerLoc (class in dv_flow.mgr) TaskRunCtxt (class in dv_flow.mgr)

U

UpToDateCtxt (class in dv_flow.mgr.uptodate_ctxt)