我有一个 kedro 节点,它返回一个熊猫数据框列表。在另一个节点我do_something()
到数据帧。例如:
def first_node():
"""returns a list"""
return list_item
def do_something(data):
"""perform same action to all list element"""
data_ls = []
for item in data:
#do thing
data_ls.append(item)
return data_ls
但是,我不想在同一个节点中执行所有操作,而是想为返回的每个列表元素创建不同的节点first_node()
。我正在为此苦苦挣扎,因为 kedro 管道希望明确提及input
and output
。有可能用kedro实现这个吗?
非常感谢!