0

我有一个 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 管道希望明确提及inputand output。有可能用kedro实现这个吗?

非常感谢!

4

0 回答 0