在Kedro中，如何在管道中提取中间数据集？

import kedro
from kedro.pipeline import node, Pipeline
from kedro.io import DataCatalog, MemoryDataSet

# 创建一个数据集对象
intermediate_data = MemoryDataSet()

# 定义一个节点，使用数据集作为输入和输出
def process_data(input_data):
    # 加载输入数据集
    data = input_data.load()
    
    # 在这里进行数据处理逻辑
    processed_data = data * 2
    
    # 保存输出数据集
    intermediate_data.save(processed_data)

# 创建一个数据目录对象，并将数据集添加到其中
data_catalog = DataCatalog({"intermediate_data": intermediate_data})

# 创建一个管道对象，并将节点添加到其中
pipeline = Pipeline([node(process_data, inputs="input_data", outputs="intermediate_data")])

# 运行管道
kedro.run(pipeline, data_catalog)