dagstream.graph_components.dags.FunctionalDag

class dagstream.graph_components.dags.FunctionalDag(name2nodes)

Parameters:

name2nodes (dict[str, IFunctionalNode])

__init__(name2nodes)

Parameters:

name2nodes (dict[str, IFunctionalNode])

Return type:

None

Methods

__init__(name2nodes)
check_exists(node)	Chech whether node exists in this functional dag.
check_last(node)
done(*node_names)	Register nodes as finished and update state
get_drawable_nodes()
get_ready()
send(node_name, result)

Attributes

is_active

Check whether unfinished functions exist or not

check_exists(node)

Chech whether node exists in this functional dag.

Parameters:

node (IFunctionalNode) – functional node to search

Returns:

True if node exists in this functional dag.

Return type:

bool

done(*node_names)

Register nodes as finished and update state

Parameters:

• *finished_nodes (IFunctionalNode) – finished nodes

• node_names (str)

Return type:

None

property is_active: bool

Check whether unfinished functions exist or not

Returns:

True if not finished functions exist

Return type:

bool