timeflux.core.branch

---

Branch base class.

branch

class timeflux.core.branch.Branch(graph=None)

Bases: timeflux.core.node.Node

Helper class that provides a standard way to create an ABC using inheritance.

Instantiate the node.

update()

Update the input and output ports.

load(graph)

Initialize the graph.

Parameters

graph (dict) – The graph.

run()

Execute the graph once.

get_port(node_id, port_id='o')

Get a port from the graph.

Parameters

• node_id (string) – The node id.

• port_id (string) – The port name. Default: o.

Returns

A reference to the requested port.

Return type

Port

set_port(node_id, port_id='i', data=None, meta=None, persistent=True)

Set a port’s data and meta.

Parameters

• node_id (string) – The node id.

• port_id (string) – The port name. Default: i.

• data (DataFrame, DataArray) – The data. Default: None.

• meta (dict) – The meta. Default: None.

• persistent (boolean) – Set the persistence of data and meta. If True, the port will not be cleared during graph execution. Default: True.