feat(12-02): update CLI processor registration
- Import SRTProcessor from processors module - Add SRTProcessor to processors list - Update PipelineConfig.steps to include 'srt' step - Pipeline will select SRTProcessor or AnalyzeProcessor based on platform Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
+4
-3
@@ -49,7 +49,7 @@ def process_command(
|
|||||||
from .pipeline.pipeline import Pipeline
|
from .pipeline.pipeline import Pipeline
|
||||||
from .pipeline.processors import (
|
from .pipeline.processors import (
|
||||||
ASRProcessor, AnalyzeProcessor, ArchiveProcessor,
|
ASRProcessor, AnalyzeProcessor, ArchiveProcessor,
|
||||||
DownloadProcessor, ParseProcessor
|
DownloadProcessor, ParseProcessor, SRTProcessor
|
||||||
)
|
)
|
||||||
from .pipeline.schemas import PipelineConfig
|
from .pipeline.schemas import PipelineConfig
|
||||||
|
|
||||||
@@ -63,13 +63,14 @@ def process_command(
|
|||||||
ParseProcessor(),
|
ParseProcessor(),
|
||||||
DownloadProcessor(),
|
DownloadProcessor(),
|
||||||
ASRProcessor(),
|
ASRProcessor(),
|
||||||
AnalyzeProcessor(),
|
SRTProcessor(), # B站视频使用
|
||||||
|
AnalyzeProcessor(), # 知乎/文章使用
|
||||||
ArchiveProcessor(),
|
ArchiveProcessor(),
|
||||||
]
|
]
|
||||||
|
|
||||||
# Create pipeline config
|
# Create pipeline config
|
||||||
config = PipelineConfig(
|
config = PipelineConfig(
|
||||||
steps=["parse", "download", "asr", "analyze", "archive"],
|
steps=["parse", "download", "asr", "srt", "analyze", "archive"],
|
||||||
output_dir=out_dir,
|
output_dir=out_dir,
|
||||||
skip_completed=skip_completed,
|
skip_completed=skip_completed,
|
||||||
)
|
)
|
||||||
|
|||||||
Reference in New Issue
Block a user