INNER CODE UNIT · Python

_run_enrichment_loop

Nuclear-Marmalade/dataforge · forge/dashboard/app.py:188

def _run_enrichment_loop(db, mode: str, workers: int, total: int) -> None:
    """Build the pipeline and run enrichment."""
    from forge.adapters.ollama import OllamaAdapter
    from forge.enrichment.pipeline import EnrichmentPipeline
    from forge.tools.database import DatabasePool

    config = _get_config()
    pool = DatabasePool(db=db)

    ollama = None
    if mode in ("ai", "both"):
        try:
            ollama = OllamaAdapter(base_url=config.ollama_url, default_model=config.ollama_model)
            _append_log(f"Connected to Ollama at {config.ollama_url}")
        except Exception as e:
            _append_log(f"Ollama not available: {e}")
            if mode == "ai":
                _append_log("ERROR: AI mode requires Ollama")

View source record →