Function start_process

processor/core.py:266–329

执行处理管道 Args: data: 处理器配置列表 input_path: 输入文件路径 output_path: 输出文件路径 initial_buffer: 初始图像缓冲区（可选，用于不从文件加载的情况）

(data: List[dict], input_path: str = None, output_path: str = None, initial_buffer: List = None)

def start_process(data: List[dict], input_path: str = None, output_path: str = None, initial_buffer: List = None):
    """
    执行处理管道

    Args:
        data: 处理器配置列表
        input_path: 输入文件路径
        output_path: 输出文件路径
        initial_buffer: 初始图像缓冲区（可选，用于不从文件加载的情况）
    """
    nodes = [PipelineContext(datum) for datum in data]

    # 设置初始 buffer
    if initial_buffer is not None:
        nodes[0].set("buffer", initial_buffer)
        nodes[0].set("buffer_loaded", True)
    elif input_path is not None:
        nodes[0].set("buffer_path", [input_path])

    # 填充 exif 信息
    if input_path is not None:
        exif = get_exif(input_path)
        for node in nodes:
            if 'exif' not in node:
                node['exif'] = exif

    # 所有处理器的输出, 0 被看作是头元素的输出
    output = nodes[0].get_buffer()

    all_buffer = [output]
    last_merger_idx = -1

    for idx, node in enumerate(nodes):
        processor = get_processor(node.get_processor_name())
        if processor is None:
            raise RuntimeError(f"Processor '{node.get_processor_name()}' not found")

        processor_instance: ImageProcessor = processor()
        if 'select' in node:
            indexes = json.loads(node['select'])
            flattened = list(chain.from_iterable([all_buffer[i] for i in indexes]))
            node.update_buffer(flattened)
        else:
            # 使用 category() 方法判断是否为 merger，避免导入 Merger 类
            if processor_instance.category() != "merger":
                node.update_buffer(output)
            else:
                # 收集下标从上一个 merger 之后, 到当前 idx 为止的 buffer
                buffers_to_merge = all_buffer[last_merger_idx + 1:idx + 1]

                # 将数组的数组展平为数组
                flattened = list(chain.from_iterable(buffers_to_merge))
                node.update_buffer(flattened)
                last_merger_idx = idx

        processor_instance.process(node)
        output = node.get_buffer()
        all_buffer.append(output)