towhee.runtime.nodes.node.Node

class towhee.runtime.nodes.node.Node(node_repr: NodeRepr, op_pool: OperatorPool, in_ques: List[DataQueue], out_ques: List[DataQueue], time_profiler: TimeProfiler)

Bases: ABC

node_info:

name func_type: operator/lambda node_type: map/filter/flat_map/window/time_window/window_all input_schema: (name, name) output_schema: (name, name, name) # operator meta info: op_info: {

hub_id: ‘’, name: ‘’, args: [], kwargs: {}, tag: ‘’

}, config: {}

Methods

initialize
process
process_step

Attributes

err_msg
name
status
uid

__init__(node_repr: NodeRepr, op_pool: OperatorPool, in_ques: List[DataQueue], out_ques: List[DataQueue], time_profiler: TimeProfiler)