Open source library

Polar Llama

A Python library for parallel LLM inference across providers, built on Polars DataFrames.

v0.6.1Released July 14, 2026
View on GitHubPyPI package
Version0.9.0latest0.8.30.8.20.8.10.8.00.7.30.7.20.7.10.7.00.6.30.6.20.6.10.6.00.5.30.5.20.5.10.5.00.3.00.2.20.2.10.2.00.1.7
You are viewing documentation for version 0.6.1. A newer version (0.9.0) is available.

Overview

Polar Llama is a Python library that enables parallel inference calls to multiple Large Language Model providers through Polars dataframes. It streamlines batch processing of AI queries without serial request delays, making it ideal for data-intensive AI applications. 0.6.1 makes large batch runs resumable: pass checkpoint= and a job that dies halfway picks up where it left off.

Concurrent Processing

Send multiple inference requests in parallel without waiting for individual completions

🔌Six Providers

OpenAI, Anthropic, Gemini, Groq, AWS Bedrock, and on-device MLX (Apple Silicon)

🧰Tool Use / MCP

Dataframe-native tool calling: emission, batch-parallel execution, and synthesis are all ordinary columns

🛡️Production Runs

Built for long batch jobs: token streaming, resumable checkpoints

Installation

Using pip

bash
pip install polar-llama==0.6.1

On-device inference (Apple Silicon)

Pulls in mlx and mlx-lm; requires an Apple Silicon Mac and Python ≥ 3.10

bash
pip install "polar-llama[local]"

Development Installation

bash
maturin develop

Quick Start

Get started with a simple example

python
import polars as pl
from polar_llama import Provider
import dotenv

dotenv.load_dotenv()

# Example questions
questions = [
    'What is the capital of France?',
    'What is the difference between polars and pandas?'
]

df = pl.DataFrame({'Questions': questions})

# Using the fluent .llama namespace (recommended)
df = df.with_columns(
    answer=pl.col('Questions').llama.inference_async(
        provider=Provider.OPENAI,
        model='gpt-4o-mini'
    )
)

What’s New in 0.6.1

New in 0.6.1

Resumable Batch Runs (Checkpointing)

inference_async(..., checkpoint="path") and inference_messages (#75)

Large jobs fail mid-run because of rate limits, network blips, and provider outages. Pass checkpoint="path" to inference_async or inference_messages and completed rows are persisted to a sidecar Parquet store as the run progresses. Re-run the same code and it resumes, skipping rows that already finished, so a job killed at 50% costs about one full pass. The API stays a lazy, DataFrame-shaped Polars expression that composes in with_columns / LazyFrame pipelines.

python
from polar_llama import inference_async, Checkpoint, Provider

out = df.with_columns(
    answer=inference_async(
        pl.col("prompt"),
        provider=Provider.OPENAI,
        model="gpt-4o-mini",
        checkpoint="run1.ckpt",   # directory of append-only Parquet parts
    )
)
# If this dies at 50%, just run it again: finished rows are served from
# the checkpoint and only the remaining rows hit the API.

# Explicit configuration
ckpt = Checkpoint("run1.ckpt", flush_every=100, retry_failed=False)
out = df.with_columns(answer=inference_async(pl.col("prompt"), checkpoint=ckpt))
Checkpoint optionDefaultMeaning
path(required)Sidecar directory of Parquet parts plus _meta.json; created if missing
flush_every100Unique pending rows sent (and flushed to disk) per chunk; bounds re-spend after a crash to one chunk
retry_failedTrueRe-attempt rows stored as failed on resume; False returns the stored error instead
on_mismatch"restart"What to do when the store's fingerprint doesn't match the current config: "restart" or "error"

Automatic Invalidation

Content keys hash the row and the whole run configuration

Each row is keyed by a sha256 content hash over the row input plus the full run configuration: provider, model, system prompt, response schema, and the endpoint base-URL override. Change any of them and old entries never match, so you can’t get a stale result from a different configuration. Hashing uses hashlib.sha256 rather than Polars’ seed- and version-unstable Expr.hash(), so resume survives library upgrades.

The store is crash-durable: each flush writes a uniquely named .tmp part and atomically renames it, so a crash mid-write leaves nothing a reader will pick up. Structured outputs and tool-use passes work unchanged. The hashing primitives live in polar_llama/keys.py so content-hash caching can reuse them.

Everything Since 0.2.2

0.6.1 is cumulative: every feature shipped in 0.2.2 is still here, plus everything added across 0.3.0, 0.5.0, 0.5.1, 0.5.2, 0.5.3, 0.6.0.

0.3.0 – 0.5.2: Tool Use, Prompt Optimization, Caching, Local MLX

Released 2026-06-10 to 2026-07-12

🧰Tool Use / MCP

tools_to_response_model, mcp_tools, execute_tool_calls, tool_results_to_message: batch-parallel tool calling over an MCP server or a Python executor (0.3.0)

🗄️Provider-Native Prompt Caching

cache=True / CacheConfig shares a cached system prefix across rows via Anthropic cache_control, with 5-minute and 1-hour TTLs (0.3.0)

🎛️Prompt Optimization Engine

Signature, Predict, evaluate, BootstrapFewShot, InstructionOptimizer: DSPy-style instruction and few-shot tuning (0.3.0)

🍎Local MLX Backend

inference_local with server and in_process engines, collapsed prefix prefill, batched quantized KV cache (0.5.0), and an on-device prompt-tuning bridge (0.5.1)

Along the way: updated default models for every provider, OPENAI_BASE_URL / ANTHROPIC_BASE_URL overrides and POLAR_LLAMA_MAX_CONCURRENCY (0.3.0), and fixes for in-process Gemma 3n inference (0.5.2). See the 0.5.2 docs for the full details.

0.5.3: Strict-Mode Taxonomy Fix

Released 2026-07-13

tag_taxonomy() works on OpenAI strict mode again. The per-field thinking reasoning is now List[{value, reasoning}] instead of a dict keyed by value name, and $ref sibling keywords are stripped from generated schemas (#51). A new warning flags Dict-typed fields in user-supplied response models.

0.6.0: Production Runs

Released 2026-07-13

ReleaseFeatureWhat shipped
0.6.0Streaminginference_stream() with an on_token(row_index, delta) callback and a Struct{text, finished} column; native SSE for OpenAI, Groq, Anthropic; GROQ_BASE_URL override

Examples & Cookbooks

Tool Use: Emit, Execute, Synthesize

The agent loop unrolled into ordinary dataframe columns

python
from polar_llama import (
    mcp_tools, tools_to_response_model, execute_tool_calls,
    tool_results_to_message, combine_messages, inference_messages, Provider,
)

tools = mcp_tools("http://localhost:8811/mcp")     # tools/list introspection
ToolCalls = tools_to_response_model(tools)          # emission schema

df = (
    df
    # 1. Emit: the LLM parameterizes N calls per row (structured output)
    .with_columns(calls=pl.col("meal").llama.inference_async(
        provider=Provider.OPENAI, model="gpt-4o-mini", response_model=ToolCalls))
    # 2. Execute: all calls across all rows, in parallel, errors as data
    .with_columns(results=execute_tool_calls(
        pl.col("calls"), transport="http://localhost:8811/mcp", tools=tools))
    # 3. Synthesize: fold results back through a second inference pass
    .with_columns(answer=inference_messages(
        combine_messages(
            pl.col("meal").llama.to_message(role="user"),
            tool_results_to_message(pl.col("results")),
        ),
        provider=Provider.OPENAI, model="gpt-4o-mini"))
)

Prompt Optimization (DSPy-style)

Declare a task, then let an optimizer tune instructions or mine few-shot demos

python
import polars as pl
from polar_llama import Predict, Signature, BootstrapFewShot, InstructionOptimizer, evaluate

# 1. Declare the task
module = Predict(
    Signature("question -> answer", instructions="Answer concisely."),
    provider="openai",
    model="gpt-4o-mini",
)

# 2. Labeled training data
trainset = pl.DataFrame({
    "question": ["What is 2+2?", "Capital of France?", "Largest planet?"],
    "answer": ["4", "Paris", "Jupiter"],
})

# 3. A metric: (gold row, prediction) -> bool | float
def exact_match(example, prediction):
    return example["answer"].strip().lower() == (prediction["answer"] or "").strip().lower()

# 4a. Bootstrap few-shot demos from rows the model already gets right
compiled = BootstrapFewShot(metric=exact_match, max_demos=4).compile(module, trainset)

# 4b. Or search for better instructions (COPRO-style)
optimizer = InstructionOptimizer(metric=exact_match, n_candidates=4)
compiled = optimizer.compile(module, trainset)
print(optimizer.history)  # [(instructions, score), ...]

# 5. Run the optimized module on new data; outputs land in pred_* columns
result = compiled(pl.DataFrame({"question": ["What is 3+3?"]}))
print(result["pred_answer"])

# Score any module against a labeled set
print(evaluate(compiled, trainset, exact_match).score)

Production Runs

Features from earlier releases for long, expensive batch jobs

python
import polars as pl
from polar_llama import (
    inference_async, Provider, inference_stream,
)

# Streaming (0.6.0+): token deltas via a callback, Struct{text, finished} per row
df = df.with_columns(
    streamed=inference_stream(pl.col("prompt"), provider=Provider.OPENAI,
                              model="gpt-4o-mini", on_token=lambda i, d: print(d, end=""))
)

On-Device Inference (Apple Silicon, in-process engine)

Batched generation via mlx-lm, no API keys, no network

python
import polars as pl
import polar_llama  # registers the .llama namespace

df = pl.DataFrame({"ticket": [
    "My laptop won't turn on even when it's plugged in.",
    "I forgot my password and I'm locked out of my account.",
]})

tagged = df.with_columns(
    tag=pl.col("ticket").llama.inference_local(
        model="mlx-community/gemma-3n-E4B-it-lm-4bit",
        system="Classify the ticket as exactly one of: Hardware, Account, Billing.",
        engine="in_process",   # on-device mlx-lm, batched over the column
        max_tokens=16,
        temperature=0.0,
    )
)

Data Analysis Pipeline

Process customer feedback at scale

python
import polars as pl
from polar_llama import string_to_message, inference_async, Provider

# Load customer feedback data
feedback_df = pl.DataFrame({
    'customer_id': [101, 102, 103, 104, 105],
    'feedback': [
        'The product is amazing but shipping was slow',
        'Great quality, highly recommend!',
        'Disappointed with customer service',
        'Perfect for my needs, will buy again',
        'Product arrived damaged, requesting refund'
    ]
})

# Create sentiment analysis prompts
sentiment_prompt = """Analyze the sentiment of this customer feedback
and classify it as Positive, Negative, or Neutral.
Also provide a brief reason.

Feedback: {feedback}"""

df = feedback_df.with_columns(
    prompt=pl.format(sentiment_prompt, pl.col('feedback'))
)

# Convert to messages and run inference
df = df.with_columns(
    message=string_to_message("prompt", message_type='user')
)

df = df.with_columns(
    sentiment_analysis=inference_async('message',
                                      provider=Provider.OPENAI,
                                      model='gpt-4o-mini')
)

# Extract key insights
print(df.select(['customer_id', 'feedback', 'sentiment_analysis']))

Vector Similarity Search

Generate embeddings, then find nearest neighbors with HNSW

python
from polar_llama import knn_hnsw, embedding_async, Provider

# Create corpus of documents
corpus = pl.DataFrame({
    "doc": ["AI research", "cooking tips", "machine learning", "recipes"]
}).with_columns(
    embedding=embedding_async(pl.col("doc"), provider=Provider.OPENAI)
)

# Create query
query = pl.DataFrame({
    "query": ["artificial intelligence"]
}).with_columns(
    query_emb=embedding_async(pl.col("query"), provider=Provider.OPENAI),
    corpus_emb=pl.lit([corpus["embedding"].to_list()])
).with_columns(
    neighbors=knn_hnsw(
        pl.col("query_emb"),
        pl.col("corpus_emb").list.first(),
        k=2  # Find 2 nearest neighbors
    )
)

# Get nearest neighbor documents
indices = query["neighbors"][0]
print(corpus[indices]["doc"])  # ['AI research', 'machine learning']

Taxonomy-Based Tagging

Classify documents with reasoning, reflection, and confidence scores

python
import polars as pl
from polar_llama import tag_taxonomy, Provider

# Define your taxonomy
taxonomy = {
    "sentiment": {
        "description": "The emotional tone of the text",
        "values": {
            "positive": "Text expresses positive emotions or favorable opinions",
            "negative": "Text expresses negative emotions or unfavorable opinions",
            "neutral": "Text is factual and objective without clear emotional content"
        }
    },
    "urgency": {
        "description": "How urgent the content is",
        "values": {
            "high": "Requires immediate attention",
            "medium": "Should be addressed soon",
            "low": "Can be addressed at any time"
        }
    }
}

df = pl.DataFrame({
    "id": [1, 2],
    "message": [
        "URGENT: Server is down!",
        "Thanks for your help yesterday."
    ]
})

result = df.with_columns(
    tags=tag_taxonomy(
        pl.col("message"),
        taxonomy,
        provider=Provider.GROQ,
        model="llama-3.3-70b-versatile"
    )
)

# Extract specific values
result.select([
    "message",
    pl.col("tags").struct.field("sentiment").struct.field("value").alias("sentiment"),
    pl.col("tags").struct.field("sentiment").struct.field("confidence").alias("confidence"),
    pl.col("tags").struct.field("urgency").struct.field("value").alias("urgency")
])

# Per-candidate reasoning: thinking is a list of {value, reasoning} (0.5.3+)
result.select(
    "id",
    pl.col("tags").struct.field("sentiment").struct.field("thinking").alias("thinking"),
).explode("thinking").unnest("thinking")

Provider Support

Six inference targets: five hosted providers plus on-device MLX

OpenAI

Default model: gpt-4o-mini

python
df = df.with_columns(
    answer=inference_async('prompt',
                          provider=Provider.OPENAI,
                          model='gpt-4o-mini')
)

Anthropic (Claude)

Default model: claude-opus-4-8; supports cache=True for prompt caching

python
df = df.with_columns(
    answer=inference_async('prompt',
                          provider=Provider.ANTHROPIC,
                          model='claude-opus-4-8',
                          system_prompt='You are a helpful assistant.',
                          cache=True)
)

AWS Bedrock

Default model: us.anthropic.claude-haiku-4-5-20251001-v1:0; region resolved from AWS_REGION / AWS_DEFAULT_REGION

python
# Requires AWS credentials configured
df = df.with_columns(
    answer=inference_async('prompt',
                          provider='bedrock',
                          model='us.anthropic.claude-haiku-4-5-20251001-v1:0')
)

Google Gemini

Default model: gemini-2.5-flash; native system_instruction and JSON-schema structured outputs

python
df = df.with_columns(
    answer=inference_async('prompt',
                          provider=Provider.GEMINI,
                          model='gemini-2.5-flash')
)

Groq

Default model: llama-3.3-70b-versatile; GROQ_BASE_URL overrides the endpoint (0.6.0+)

python
df = df.with_columns(
    answer=inference_async('prompt',
                          provider=Provider.GROQ,
                          model='llama-3.3-70b-versatile')
)

Local (Apple Silicon / MLX)

No API key, no network: the server engine points at a local OpenAI-compatible endpoint, and in_process drives mlx-lm directly

python
# engine="server" (default): point at a local server you started yourself
df = df.with_columns(
    answer=pl.col('prompt').llama.inference_local(
        model='mlx-community/gemma-4-e2b-it-4bit',
        engine='server',
        base_url='http://localhost:8080',
    )
)

# engine="in_process": batched generation directly via mlx-lm
df = df.with_columns(
    answer=pl.col('prompt').llama.inference_local(
        model='mlx-community/gemma-4-e2b-it-4bit',
        engine='in_process',
        max_tokens=256,
    )
)

API Surface

Core expressions exported from polar_llama

FunctionPurpose
inference_async(expr, *, provider, model, response_model, cache, system_prompt, checkpoint)Parallel async inference; plus prompt caching, checkpointing
inference(expr, *, provider, model, response_model)Synchronous inference (deprecated in favor of inference_async)
inference_messages(expr, *, provider, model, response_model, cache, checkpoint)Multi-turn conversation inference over JSON or List(Struct) message arrays
inference_stream(expr, *, provider, model, on_token, messages)Token-by-token streaming; returns Struct{text, finished} per row
string_to_message(expr, *, message_type)Convert text to a {role, content} message
combine_messages(*exprs)Merge message columns/arrays into one ordered conversation
tag_taxonomy(expr, taxonomy, *, provider, model)Classify text against a taxonomy with reasoning, reflection, and confidence
embedding_async(expr, *, provider, model)Parallel embedding generation (OpenAI, Gemini, Bedrock)
cosine_similarity / dot_product / euclidean_distance(vec1, vec2)Rust-powered vector similarity metrics
knn_hnsw(query_expr, reference_expr, *, k)Stateless approximate nearest-neighbor search via HNSW
mcp_tools(transport, *, timeout_s)Fetch tool definitions from an MCP server (tools/list)
tools_to_response_model(tools, *, model_name)Build a Pydantic emission schema so the LLM emits structured tool calls
execute_tool_calls(expr, *, transport, executor, tools, concurrency, timeout_s)Run every emitted call of every row in parallel; failures are data
tool_results_to_message(expr, *, role)Render tool results as a message for the synthesis inference pass
Signature / Predict / evaluate / BootstrapFewShot / InstructionOptimizerDSPy-style prompt optimization engine (polar_llama.optimize)
Checkpoint(path, *, flush_every, retry_failed, on_mismatch)Checkpoint store configuration for checkpoint=
col(...).llama.inference_local(*, model, system, engine, base_url, max_tokens, temperature, top_p, stop)On-device inference on Apple Silicon via mlx-lm
polar_llama.local.make_local_inference_fn(model, *, engine, collapse, max_tokens, ...)Build an inference_fn that backs the optimizer with on-device Gemma 3n

Every expression is also available on the fluent .llama namespace (pl.col("text").llama.inference_async(...), .llama.to_message(...), .llama.embedding(...), .llama.inference_stream(...), and so on).

Advanced Features

Environment Configuration

Set up your API keys and overrides in a .env file:

.envbash
OPENAI_API_KEY=your_openai_key
ANTHROPIC_API_KEY=your_anthropic_key
GEMINI_API_KEY=your_gemini_key
GROQ_API_KEY=your_groq_key
AWS_ACCESS_KEY_ID=your_aws_key
AWS_SECRET_ACCESS_KEY=your_aws_secret
AWS_REGION=us-east-1

# Optional endpoint overrides for proxies and gateways (0.3.0+)
OPENAI_BASE_URL=https://your-proxy.example.com
ANTHROPIC_BASE_URL=https://your-proxy.example.com
GROQ_BASE_URL=https://your-proxy.example.com         # 0.6.0+

# Bound concurrent in-flight requests per batch (default: 64)
POLAR_LLAMA_MAX_CONCURRENCY=64

# Local MLX backend (Apple Silicon only)
POLAR_LLAMA_LOCAL_COLLAPSE=1        # collapsed prefix prefill for inference_local (0.5.1+)
POLAR_LLAMA_LOCAL_KV_BITS=4         # quantized batched KV cache, 0.5.0+ (mutually exclusive with COLLAPSE)

Prompt Caching

Share a cached system prefix across rows (Anthropic cache_control):

python
from polar_llama import CacheConfig, CacheStrategy

# Simple: enable automatic caching
df = df.with_columns(
    response=inference_async(
        pl.col("prompt"),
        provider=Provider.ANTHROPIC,
        model="claude-opus-4-8",
        system_prompt="You are a careful, concise research assistant.",
        cache=True,   # AUTO strategy, min_tokens=1024, ttl="5m"
    )
)

# Advanced: configure caching behavior explicitly
config = CacheConfig(strategy=CacheStrategy.SYSTEM_PROMPT, ttl="1h")
df = df.with_columns(
    response=inference_async(pl.col("prompt"), cache=config)
)

Testing

Run tests with configured providers:

bash
pip install -r tests/requirements.txt
pytest tests/ -v
cargo test --test model_client_tests -- --nocapture

# Local MLX backend: CPU-safe logic tests only (no GPU, no mlx import)
pytest tests/ -m "not local_gpu"

Changelog Highlights (0.5.2 → 0.6.1)

  • 0.6.1: checkpoint="path" / Checkpoint(...) on inference_async and inference_messages: resumable runs over a crash-durable Parquet store keyed by content + config hash
  • 0.6.0: inference_stream() with an on_token(row_index, delta) callback and a Struct{text, finished} column; native SSE for OpenAI, Groq, Anthropic; GROQ_BASE_URL override
  • 0.5.3: tag_taxonomy() works on OpenAI strict mode again: thinking is now List[{value, reasoning}] and $ref siblings are stripped (#51); new warning for Dict-typed response models
  • 0.5.2: fixed in-process local inference on Gemma 3n (mlx-lm #1384 patch applied at load time; a masked ZeroDivisionError in BatchGenerator teardown no longer hides the real error)
  • 0.3.0 – 0.5.1: tool use / MCP, provider-native prompt caching, DSPy-style prompt optimizer, local MLX backend, and the on-device prompt-tuning bridge

Common Use Cases

📊Data Analysis

Process large datasets with AI insights: sentiment analysis, classification, entity extraction with validated structured outputs

🛡️Long-Running Batch Jobs

Resume after crashes, track spend per row, and never pay twice for the same request

🧰Tool-Augmented Pipelines

Let the LLM call databases, internal APIs, or MCP servers at scale, with every call, result, and retry as an ordinary dataframe column

🔒Private, Local Inference

Run classification, extraction, or tuning on local models with no API keys and no data leaving the machine

Resources
GitHub RepositoryPyPI PackagePolars Documentation

Licensed under MIT.

Questions or issues? Open one on GitHub.