dagstream.graph_components.nodes.FunctionalNode

class dagstream.graph_components.nodes.FunctionalNode(user_function, *, mut_node_name=None)[source]
Parameters:

  • user_function (Callable[[Any], Any])

  • mut_node_name (str | None)

__init__(user_function, *, mut_node_name=None)[source]
Parameters:

  • user_function (Callable[[Any], Any])

  • mut_node_name (str | None)

Return type:

None

Methods

__init__(user_function, *[, mut_node_name])

get_received_args()

get_user_function()

precede(*nodes[, pipe])

prepare()

receive_args(val)

run(*args, **kwargs)

succeed(*nodes[, pipe])

Attributes

display_name

mut_name

n_predecessors

n_successors

predecessors

successors