Pi AI (3)

Last updated Oct 22, 2026 To use Workers AI with Pi AI ↗︎, use createAI from agents/models/pi-ai. It returns Pi AI Model objects, so Workers AI models work with Pi AI's stream and complete, with Pi Durable ↗︎, and with the Pi harness. This page covers Workers AI models. For AI Gateway catalog models, fallback, gateway options, and the full reference, refer to Pi AI.

Setup

Install the Agents SDK and Pi AI. createAI needs @earendil-works/pi-ai@~1.4.0:

npmyarnpnpmbun

npm i agents @earendil-works/pi-ai

yarn add agents @earendil-works/pi-ai

pnpm add agents @earendil-works/pi-ai

bun add agents @earendil-works/pi-ai

Add the AI binding to your Wrangler configuration:

{
    "ai": {
        "binding": "AI",
    },
}

[ai]
binding = "AI"

Generate text

Name a Workers AI model by its @cf/ id. The provider carries Pi AI's entry points, so nothing is registered globally:

import { createAI } from "agents/models/pi-ai";

export default {
    async fetch(request, env) {
        const ai = createAI({ binding: env.AI });

        const reply = await ai.complete(ai("@cf/zai-org/glm-4.7-flash"), {
            messages: [
                { role: "user", content: "What is Cloudflare?", timestamp: Date.now() },
            ],
        });

        // `content` holds text, thinking, and tool call parts.
        const text = reply.content
            .filter((part) => part.type === "text")
            .map((part) => part.text)
            .join("");

        return Response.json({ text });
    },
};

import { createAI } from "agents/models/pi-ai";

export default {
    async fetch(request: Request, env: Env) {
        const ai = createAI({ binding: env.AI });

        const reply = await ai.complete(ai("@cf/zai-org/glm-4.7-flash"), {
            messages: [
                { role: "user", content: "What is Cloudflare?", timestamp: Date.now() },
            ],
        });

        // `content` holds text, thinking, and tool call parts.
        const text = reply.content
            .filter((part) => part.type === "text")
            .map((part) => part.text)
            .join("");

        return Response.json({ text });
    },
};

Stream text

ai.stream() returns Pi AI's event stream. ai.streamSimple() and ai.completeSimple() take Pi AI's simple options, such as a reasoning level and maxTokens:

const model = ai("@cf/zai-org/glm-4.7-flash");
const context = {
    messages: [{ role: "user", content: "Hi", timestamp: Date.now() }],
};

for await (const event of ai.stream(model, context)) {
    // text_delta, thinking_delta, toolcall_*, done, error
}

A compatibility layer turns each Workers AI model's response into the shape Pi AI's parsers read, so tool calls and reasoning work the same across model families.

Set model details

A Workers AI id that Pi AI does not list resolves with a 128,000 token context window, 8,192 output tokens, and zero cost. Pass the real values when you know them:

const model = ai("@cf/zai-org/glm-4.7-flash", {
    contextWindow: 131_072,
    maxTokens: 16_384,
});

Generate images

const images = ai.images("@cf/black-forest-labs/flux-1-schnell", { steps: 8 });
const result = await ai.generateImages(images, {
    input: [{ type: "text", text: "A red bicycle" }],
});

Use AI Gateway

Every request goes through AI Gateway. Set the gateway with id, which defaults to default:

const ai = createAI({ binding: env.AI, id: "my-gateway" });

To call from outside a Worker, pass accountId and apiToken instead of binding. For gateway options, catalog models, and fallback, refer to Pi AI.

Was this helpful?

YesNo

On this page

Pi AI (3) - 图1Docs

{"@context":"https://schema.org","@type":"TechArticle","@id":"https://developers.cloudflare.com/workers-ai/configuration/pi-ai/#page","headline":"Pi AI","description":"Use Workers AI models with Pi AI through createAI from agents/models/pi-ai.","url":"https://developers.cloudflare.com/workers-ai/configuration/pi-ai/","inLanguage":"en","image":"https://developers.cloudflare.com/workers-ai/configuration/pi-ai/og.png?v=927ed23e0b5e5a1a","dateModified":"2026-10-22","publisher":{"@type":"Organization","name":"Cloudflare","description":"One platform for your apps, agents, and workforce. Build, secure, and scale without managing infrastructure","url":"https://www.cloudflare.com/","sameAs":["https://github.com/cloudflare","https://www.linkedin.com/company/cloudflare","https://x.com/cloudflare"],"logo":{"@type":"ImageObject","url":"https://developers.cloudflare.com/logo.svg"},"address":{"@type":"PostalAddress","streetAddress":"101 Townsend St","addressLocality":"San Francisco","addressRegion":"CA","postalCode":"94107","addressCountry":"US"},"contactPoint":[{"@type":"ContactPoint","contactType":"Customer Support","url":"https://support.cloudflare.com/","availableLanguage":["English"]},{"@type":"ContactPoint","contactType":"Sales","url":"https://www.cloudflare.com/contact/","availableLanguage":["English"]}]},"isPartOf":{"@type":"WebSite","@id":"https://developers.cloudflare.com/#website","name":"Cloudflare Docs","url":"https://developers.cloudflare.com/"}}

description: Queue large inference workloads for asynchronous processing with the Workers AI Batch API. title: Asynchronous Batch API image: https://developers.cloudflare.com/workers-ai/features/batch-api/og.png?v=77cfb4ef80ef74d9

Skip to content

Documentation Index
Fetch the complete documentation index at: https://developers.cloudflare.com/workers-ai/llms.txt
Use this file to discover all available pages before exploring further.