Index

A

add_edge() (seaflow.schedulers.dag.DAGer method)

add_node() (seaflow.schedulers.dag.DAGer method)

B

BaseDataCatalog (class in seaflow.ios.io)

BaseRunner (class in seaflow.runners.sequencerunner)

C

collect_parameter_data_before_node_run_locally() (seaflow.hooks.hook.LocalDataCatalogPlugin method) (seaflow.hooks.hook.LocalDatacatalogSpecs method)

create_hook_manager() (seaflow.hooks.hook.HookManager method)

D

DAGBaseRunner (class in seaflow.runners.dagrunner) DAGer (class in seaflow.schedulers.dag) DAGerMeta (class in seaflow.schedulers.dag) DAGManagerDict (class in seaflow.schedulers.dag)

DAGRunnerFunction (class in seaflow.runners.dagrunner) DAGRunnerNode (class in seaflow.runners.dagrunner) DirectedAcyclicGraph (class in seaflow.schedulers.dag) dispath_algorithm_with_kahn() (seaflow.schedulers.dag.DAGer method) draw() (seaflow.schedulers.dag.DAGer method)

E

execute() (seaflow.runners.dagrunner.DAGBaseRunner class method) (seaflow.runners.dagrunner.DAGRunnerFunction method) (seaflow.runners.dagrunner.DAGRunnerNode method) (seaflow.runners.sequencerunner.BaseRunner class method) (seaflow.runners.sequencerunner.SequentialRunner method)

execute_algorithm_with_ray() (seaflow.runners.dagrunner.DAGRunnerFunction method) (seaflow.runners.dagrunner.DAGRunnerNode method)

F

func (seaflow.nodes.node.Node property)

G

get_edge_attributes() (seaflow.schedulers.dag.DAGer method) get_edge_neighbor() (seaflow.schedulers.dag.DAGer method) get_func() (seaflow.nodes.node.Node method) get_function_obj() (seaflow.schedulers.dag.DAGer method) get_graph_obj() (seaflow.schedulers.dag.DAGer method)

get_hook_manager_instance() (seaflow.hooks.hook.HookManager method) get_inputs() (seaflow.nodes.node.Node method) get_name() (seaflow.nodes.node.Node method) get_node_attributes() (seaflow.schedulers.dag.DAGer method) get_node_neighbor() (seaflow.schedulers.dag.DAGer method) get_outputs() (seaflow.nodes.node.Node method)

H

HookManager (class in seaflow.hooks.hook)

I

init_job_queue_with_kahn() (seaflow.schedulers.dag.DAGer method) inputs (seaflow.nodes.node.Node property)

inputs() (seaflow.schedulers.pipeline.Pipeline method) instance (seaflow.schedulers.dag.DAGerMeta attribute)

K

kahnclassification_algorithm() (seaflow.schedulers.dag.DAGer method)

KahnScheduler (class in seaflow.schedulers.dag)

L

load() (seaflow.ios.io.BaseDataCatalog class method) (seaflow.ios.io.LocalDataCatalog method)

LocalDataCatalog (class in seaflow.ios.io) LocalDataCatalogPlugin (class in seaflow.hooks.hook) LocalDatacatalogSpecs (class in seaflow.hooks.hook)

M

modify_edge() (seaflow.schedulers.dag.DAGer method) modify_node() (seaflow.schedulers.dag.DAGer method) module seaflow seaflow.hooks seaflow.hooks.hook seaflow.ios seaflow.ios.io seaflow.nodes seaflow.nodes.node seaflow.runners seaflow.runners.dagrunner seaflow.runners.sequencerunner seaflow.schedulers seaflow.schedulers.dag seaflow.schedulers.pipeline

N

name (seaflow.nodes.node.Node property)

names() (seaflow.schedulers.pipeline.Pipeline method) Node (class in seaflow.nodes.node)

O

outputs (seaflow.nodes.node.Node property)

outputs() (seaflow.schedulers.pipeline.Pipeline method)

P

Pipeline (class in seaflow.schedulers.pipeline)

Q

query_edge() (seaflow.schedulers.dag.DAGer method)

query_node() (seaflow.schedulers.dag.DAGer method)

R

register() (seaflow.schedulers.dag.DAGer method) register_plugins() (seaflow.hooks.hook.HookManager method) release() (seaflow.ios.io.BaseDataCatalog class method) (seaflow.ios.io.LocalDataCatalog method)

remove_edge() (seaflow.schedulers.dag.DAGer method) remove_node() (seaflow.schedulers.dag.DAGer method) run() (seaflow.nodes.node.Node method)

S

save() (seaflow.ios.io.BaseDataCatalog class method) (seaflow.ios.io.LocalDataCatalog method) seaflow module seaflow.hooks module seaflow.hooks.hook module seaflow.ios module seaflow.ios.io module seaflow.nodes module seaflow.nodes.node module

seaflow.runners module seaflow.runners.dagrunner module seaflow.runners.sequencerunner module seaflow.schedulers module seaflow.schedulers.dag module seaflow.schedulers.pipeline module SequentialRunner (class in seaflow.runners.sequencerunner) show_edges() (seaflow.schedulers.dag.DAGer method) show_nodes() (seaflow.schedulers.dag.DAGer method) store_cache_data_after_node_run_locally() (seaflow.hooks.hook.LocalDataCatalogPlugin method) (seaflow.hooks.hook.LocalDatacatalogSpecs method)

T

toposort_algorithm() (seaflow.schedulers.dag.DAGer method)