starmen1265
72d75e3454
- Add Pipeline import from kb_workflow.pipeline.pipeline - Add Pipeline to __all__ exports list - Enables: from kb_workflow.pipeline import Pipeline Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
68 lines
1.5 KiB
Python
68 lines
1.5 KiB
Python
"""KB Pipeline - 工作流管道基础设施
|
|
|
|
提供内容处理工作流的核心 Schema 和工具。
|
|
"""
|
|
|
|
from kb_workflow.pipeline.schemas import (
|
|
StepInput,
|
|
StepOutput,
|
|
StepResult,
|
|
StepStatus,
|
|
StepRecord,
|
|
WorkflowState,
|
|
StepDefinition,
|
|
)
|
|
from kb_workflow.pipeline.state import WorkflowStateManager
|
|
from kb_workflow.pipeline.errors import (
|
|
KBError,
|
|
NetworkError,
|
|
ValidationError,
|
|
SystemError,
|
|
AuthError,
|
|
ErrorType,
|
|
)
|
|
from kb_workflow.pipeline.config import KBSettings, get_settings
|
|
from kb_workflow.pipeline.retry import retry_on_network_error
|
|
from kb_workflow.pipeline.link_parser import LinkParser, ParsedLink
|
|
from kb_workflow.pipeline.idempotency import IdempotencyChecker
|
|
from kb_workflow.pipeline.platforms import PlatformAdapter, BilibiliAdapter, ZhihuAdapter
|
|
from kb_workflow.pipeline.pipeline import Pipeline
|
|
|
|
__all__ = [
|
|
# Schemas
|
|
"StepInput",
|
|
"StepOutput",
|
|
"StepResult",
|
|
"StepStatus",
|
|
"StepRecord",
|
|
"WorkflowState",
|
|
"StepDefinition",
|
|
# State
|
|
"WorkflowStateManager",
|
|
# Errors
|
|
"KBError",
|
|
"NetworkError",
|
|
"ValidationError",
|
|
"SystemError",
|
|
"AuthError",
|
|
"ErrorType",
|
|
# Config
|
|
"KBSettings",
|
|
"get_settings",
|
|
# Retry
|
|
"retry_on_network_error",
|
|
# Link Parser
|
|
"LinkParser",
|
|
"ParsedLink",
|
|
# Idempotency
|
|
"IdempotencyChecker",
|
|
# Platform Adapters
|
|
"PlatformAdapter",
|
|
"BilibiliAdapter",
|
|
"ZhihuAdapter",
|
|
# Pipeline
|
|
"Pipeline",
|
|
]
|
|
|
|
__version__ = "0.1.0"
|