dagstream.graph_components.nodes.node_state.ReadyNodeState

class dagstream.graph_components.nodes.node_state.ReadyNodeState(n_predecessors)

Parameters:

n_predecessors (int)

__init__(n_predecessors)

Parameters:

n_predecessors (int)

Return type:

None

Methods

__init__(n_predecessors)
forward()

Attributes

is_finished
is_ready
n_predecessors