diff --git a/kb-workflow/kb_workflow.py b/kb-workflow/kb_workflow.py index 1851637..73775cc 100644 --- a/kb-workflow/kb_workflow.py +++ b/kb-workflow/kb_workflow.py @@ -30,7 +30,8 @@ def process_command( Args: url: URL to process - output_dir: Optional output directory for content + output_dir: Optional output directory for content. Defaults to + KB_INTERMEDIATE_PATH env var or ~/work/intermediate/analysis/ skip_completed: Skip already completed steps (default True) Returns: @@ -42,13 +43,15 @@ def process_command( sys.path.insert(0, str(project_root)) try: + from kb_pipeline.config import get_settings from kb_pipeline.pipeline import Pipeline from kb_pipeline.processors import ASRProcessor, AnalyzeProcessor, DownloadProcessor, ParseProcessor from kb_pipeline.schemas import PipelineConfig async def run_pipeline(): - # Determine output directory - out_dir = Path(output_dir) if output_dir else Path.cwd() + # Determine output directory - default to intermediate_path + settings = get_settings() + out_dir = Path(output_dir) if output_dir else Path(settings.intermediate_path) # Create processors processors = [