# -*- 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"]