BIDI_EXTRACTION_AI/BiddingKG/dl/pipeline/__init__.py

# -*- coding: utf-8 -*-
"""编排层（PIPELINE）。

只负责编排，不写复杂抽取逻辑。所有 Stage 共享一个 PipelineContext，
替代当前 extract.py 中函数间传递的大量散列变量。

按 ARCHITECTURE.md §4.1 分层原则：
    1. pipeline 只负责编排，不写复杂抽取逻辑。
    2. 只有 pipeline 可以组合 CORE 与 RULE。

Phase 8 已实现：
    context.py  <- PipelineContext 数据结构
    pipeline.py <- Pipeline 主编排器（run(ctx) 统一入口）
    stages/     <- Stage 子目录（后续细化拆分用）

Pipeline 是同步模式（single_server）和队列模式（queue_worker）的统一调用入口。
"""
from __future__ import absolute_import

from BiddingKG.dl.pipeline.context import PipelineContext
from BiddingKG.dl.pipeline.pipeline import Pipeline

__all__ = ["PipelineContext", "Pipeline"]