set_attr
函数功能
设置FlowNode的属性。
函数原型
set_attr(attr_name, attr_value)
参数说明
参数名称 |
数据类型 |
取值说明 |
---|---|---|
attr_name |
str |
属性名称 当前支持如下三种:
|
attr_value |
Union[bool, str, int] |
属性值。 |
返回值
正常场景下返回None。
返回“TypeError”表示参数类型不正确。
调用示例
import dataflow as df pp = df.FuncProcessPoint(...) flow_node = df.FlowNode(...) flow_node.set_attr("_flow_attr",True) flow_node.set_attr("_flow_attr_depth",5) flow_node.set_attr("_flow_attr_enqueue_policy","FIFO")
约束说明
通过_flow_attr_depth和_flow_attr_enqueue_policy设置depth和policy需要先使能_flow_attr,否则不会生效。
父主题: dataflow.FlowNode