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 = [