towhee.runtime.node_repr.NodeRepr

class towhee.runtime.node_repr.NodeRepr(uid: str, inputs: Tuple, outputs: Tuple, iter_info: IterationRepr, op_info: OperatorRepr, config: Dict[str, Any], next_nodes: List, in_edges: Optional[List] = None, out_edges: Optional[List] = None)[source]

Bases: object

NodeRepr for node representations.

Parameters:
  • name (str) – Name of the node, such as ‘_input’, ‘_output’ and id for the node.

  • inputs (Tuple) – Input schema to this node.

  • outputs (Tuple) – Output schema to this node.

  • iter_info (IterationRepr) – The iteration to this node.

  • op_info (OperatorRepr) – The operator to this node.

  • config (Dict[str, any]) – The configuration to this node.

  • next_nodes (`List’) – The next nodes.

  • in_edges (List) – The input edges about data queue schema, defaults to None.

  • out_edges (List) – The output edges about data queue schema, defaults to None.

Methods

from_dict

Return a NodeRepr from a description dict.

Attributes

config

in_edges

inputs

iter_info

name

next_nodes

op_info

out_edges

outputs

uid

__init__(uid: str, inputs: Tuple, outputs: Tuple, iter_info: IterationRepr, op_info: OperatorRepr, config: Dict[str, Any], next_nodes: List, in_edges: Optional[List] = None, out_edges: Optional[List] = None)[source]
static from_dict(uid: str, node: Dict[str, Any]) NodeRepr[source]

Return a NodeRepr from a description dict.

Parameters:
  • uid (str) – Node id.

  • node (Dict[str, Any]) – Dictionary about node info from dag.

Returns:

NodeRepr object.