Function run

src/ultrarag/client.py:2089–2116

Run UltraRAG pipeline with given configuration. Args: config_path: Path to pipeline configuration file param_path: Optional path to parameter file return_all: Whether to return all intermediate results is_demo: Whether to run in demo mode Returns: Pi

(
    config_path: str,
    param_path: Optional[Union[str, Path]] = None,
    return_all: bool = False,
    is_demo: bool = False,
)

async def run(
    config_path: str,
    param_path: Optional[Union[str, Path]] = None,
    return_all: bool = False,
    is_demo: bool = False,
) -> Any:
    """Run UltraRAG pipeline with given configuration.

    Args:
        config_path: Path to pipeline configuration file
        param_path: Optional path to parameter file
        return_all: Whether to return all intermediate results
        is_demo: Whether to run in demo mode

    Returns:
        Pipeline execution results
    """

    log_server_banner(Path(config_path).stem)

    context = load_pipeline_context(config_path, param_path)

    client = create_mcp_client(context["mcp_cfg"])

    async with client:
        result = await execute_pipeline(client, context, is_demo, return_all)

    return result


logging.getLogger("mcp").setLevel(logging.WARNING)