Skip to main content

kazenai

Stop your AI agents from burning your budget. Catch loops before they catch you.

PyPI Python 3.10+ License

Install: PyPI · kazenai · Customer SDK: kazenai-finops · Docs: docs.kazenai.com · Products: kazenai.com

Source: github.com/kazenai-ai/kazenai-core


What is this?

kazenai is the core Python SDK behind KazenAI’s economic control layer for AI agents. One call — monitor() — wraps your OpenAI or Anthropic client and:

  1. Blocks overspend before the provider call (BudgetExceeded)
  2. Detects runaway loops before another LLM request
  3. Optionally ships evidence to Agent FinOps / Agent Lens as canonical KazenEvents

Most observability tools tell you what went wrong after the bill. KazenAI can stop the call that would cause it.

Traditional tools:  LLM call → response → log cost → dashboard shows overspend
KazenAI:            Pre-flight check → BLOCKED → LLM call never made

Install

python -m pip install "kazenai[openai]==1.1.3"
# Most teams install the customer package instead:
python -m pip install "kazenai-finops[openai]==1.1.3"
# Anthropic:
# python -m pip install "kazenai-finops[anthropic]==1.1.3"
# Both providers:
# python -m pip install "kazenai-finops[providers]==1.1.3"

kazenai-finops re-exports this SDK and is the recommended install for product integrations. Provider extras keep the provider SDKs within the supported ranges (openai>=1.40,<3, anthropic>=0.39,<1).

KazenAI is tested on OpenAI 1.109.1 and 2.48.0 and Anthropic 0.125.0, and the OpenAI and Anthropic paths are verified against the live APIs. Full list: Supported integrations.

Requires Python 3.10+.


Quick start

import os
from openai import OpenAI
from kazenai import monitor, BudgetExceeded

# Optional FinOps ingest (env only — not monitor kwargs):
#   export KAZENAI_FINOPS_API_KEY=kz_...
#   export KAZENAI_FINOPS_INGEST_URL=https://finops.example.com

client = monitor(
    OpenAI(),
    agent_id="support-agent",
    max_budget_usd=5.00,
    debug=True,
)

try:
    client.chat.completions.create(
        model="gpt-4o-mini",
        messages=[{"role": "user", "content": "hello"}],
    )
except BudgetExceeded as e:
    print("hard budget cap:", e)

Your call sites stay the same — monitor() wraps the client.

With debug=True you’ll see spend as the run progresses:

[KazenAI] step=1  gpt-4o-mini  cost=$0.0043  total=$0.0043  proj=$0.21/$5.00  OK
[KazenAI] step=8  gpt-4o-mini  cost=$0.0039  total=$0.43    proj=$4.91/$5.00  WARN:budget_87pct
[KazenAI] step=9  gpt-4o-mini  BLOCKED:budget  spent=$5.00  limit=$5.00

Illustrative debug output — not a customer bill or savings claim.


What you get

Capability Behavior
Hard budget cap BudgetExceeded before the provider call
Soft trajectory pause KazenCircuitBreaker after a completed call when projection trips
Loop detection Blocks high-risk repeat patterns before another provider call
Event ingest Optional HttpSink batches to Agent FinOps when URL + API key are set
Shared schema Canonical KazenEvent via kazen-event-schema

Supported today

Path Status
OpenAI chat.completions.create / .stream / .parse, sync and async, streaming and non-streaming Supported, verified against the live API
Anthropic messages.create / .stream, sync and async, streaming and non-streaming Supported, verified against the live API
LangChain ChatOpenAI / ChatAnthropic Supported when bound with bind_monitored_chat_openai / bind_monitored_chat_anthropic
LangGraph Supported when the graph declares every provider client its nodes use; raw clients created inside nodes are not intercepted
LiteLLM proxy Supported with application-owned or gateway-owned accounting (gateway-owned streaming settlement not yet verified)
CrewAI Preview: bind_crew_llm_client works for sequential crews; not yet a supported path
OpenAI Responses API / Realtime, AutoGen Not supported

Streaming

from kazenai import StreamCutoffError, monitor
from openai import OpenAI

client = monitor(
    OpenAI(),
    max_budget_usd=1.00,
    stream_cutoff_usd=0.01,  # optional local observable-output guard
)

try:
    with client.chat.completions.create(
        model="gpt-4o-mini",
        stream=True,
        messages=[{"role": "user", "content": "Explain this result"}],
    ) as stream:
        for chunk in stream:
            ...
except StreamCutoffError:
    # The client attempted to close future output. Final provider billing may
    # remain pending when authoritative final usage was not received.
    pass

monitor() requests final OpenAI usage and settles exact cost when authoritative usage arrives. OpenAI chat.completions.stream(...), Anthropic messages.create(..., stream=True), and the messages.stream(...) context manager follow the same finalize-once accounting lifecycle. A shared reservation is marked in-flight at provider dispatch. Early cancellation, provider failure, or missing final usage moves it to pending reconciliation—never an exact zero and never released as an unstarted call.

stream_cutoff_usd estimates only output observable by the client. It cannot see hidden reasoning or guarantee that the provider stopped generating or billing immediately. stream_enforcement=True is deprecated.

The official lazy OpenAI helper is supported as well. Its reservation is marked provider_started when the context manager is entered:

with client.chat.completions.stream(
    model="gpt-4o-mini",
    messages=[{"role": "user", "content": "Explain this result"}],
) as stream:
    for event in stream:
        ...

Local and shared enforcement

  • Hard cap works without FinOps network — deny even when ingest is offline
  • Low overhead — budget and loop checks stay on the hot path
  • Shared policies can fail closed — production/staging modes deny when a required shared reservation cannot be obtained

An explicitly configured development fail-open path retains only the local client safeguards. It does not preserve a cross-process or account-wide budget guarantee.

Multi-model workflows

Each monitor(..., max_budget_usd=...) client has its own cap, so a workflow with one client per provider would add those caps up. Share one instead:

from kazenai import SharedBudget, monitor

budget = SharedBudget(max_usd=1.00)
planner = monitor(OpenAI(), budget=budget)
writer = monitor(Anthropic(), budget=budget)

In LangChain, bind chat models with bind_monitored_chat_openai / bind_monitored_chat_anthropic (both accept budget=). In LangGraph, declare every provider client the nodes use: declare_langgraph_control_boundary(graph, planner, writer) then wrap_graph(graph, capability="control", guarded_clients=[planner, writer]). Across processes or machines, give every client the same workflow_id and set a workflow limit in Agent FinOps.

A provider refusal before any output (HTTP 4xx such as unknown model, invalid key or rate limit) settles at exactly $0; timeouts and 5xx stay pending for reconciliation. Models with no known price are blocked before dispatch unless priced via KAZENAI_PRICING_JSON.


Optional FinOps environment variables

Variable Purpose
KAZENAI_FINOPS_INGEST_URL / KAZENAI_FINOPS_URL FinOps base URL for shared reservations and event ingest
KAZENAI_FINOPS_API_KEY Credential for FinOps budget and event requests
KAZENAI_DEPLOYMENT_MODE production / staging require fail-closed shared reservations
KAZENAI_FINOPS_RESERVE_TIMEOUT_S Timeout for a shared pre-call reservation
KAZENAI_TIMELINE_PATH Optional local JSONL evidence path
KAZENAI_SDK_SETTLE_QUEUE_DIR Persistent private directory for pending settlement intents

Pass max_budget_usd (or budget=SharedBudget(...)), org_id, project_id, workspace_id and attribution fields directly to monitor(); they are not inferred from similarly named environment variables.

For shared Control deployments, read Settlement recovery. Run the settlement flusher on a schedule; processes on one host can share a queue directory, but the queue does not coordinate across hosts.


Packages in the stack

Package Role
kazenai Core monitor() engine (this repo)
kazenai-finops Customer-facing SDK (recommended install)
kazen-event-schema Shared event contract across FinOps / Lens / SDKs

Contributing

Issues and pull requests that improve budget and loop reliability are welcome — see CONTRIBUTING.md. Maintainers release with RELEASING.md.

Products and design-partner enquiries: kazenai.com · founder@kazenai.com


License

Apache License 2.0. See LICENSE and NOTICE.

Metadata

Release files for kazenai 1.1.3

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for kazenai 1.1.3
File Size Uploaded
kazenai-1.1.3.tar.gz 156.3 kB Details

Built distribution (wheel)

Table of built distributions (wheels) for kazenai 1.1.3
File Interpreter ABI Platform
kazenai-1.1.3-py3-none-any.whl Python 3 none any Details

Total release size: 331.2 kB

Release files / kazenai-1.1.3.tar.gz

Download URL kazenai-1.1.3.tar.gz
Size 156.3 kB
Tags Source
SHA-256 checksum
How to use checksums
a812678187b76f91fe684e95b23359b8e2ae5c2986d202c9d71fc54ac6245967
BLAKE2b-256 checksum
How to use checksums
21d60b961f2b9f58b7547d3517053dcd04a741fd62f19c3adac24af5e028f461
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
Yes
Uploaded via twine/7.0.0 CPython/3.13.14

Provenance

Provenance describes where a file came from. On PyPI, provenance is shared via attestations, which provide a verifiable record of the build or publishing details. View details, limitations and caveats.

PyPI Publish Attestation

PyPI verified that this artifact, at this checksum, originated from the publisher listed below.

Signed by GitHub Actions, verified by PyPI on Oct 12, 2026.

Transparency log

Release files / kazenai-1.1.3-py3-none-any.whl

Download URL kazenai-1.1.3-py3-none-any.whl
Size 174.9 kB
Tags Python 3
SHA-256 checksum
How to use checksums
ecf580ef8e0bf56783f6bf0c4426952d8257b1e80a84e0ca5aab45a86a42beb3
BLAKE2b-256 checksum
How to use checksums
8c3cc0282b267d31206fea772ed6bc92234a9f1ffffe4d6ecff4486b2292608b
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
Yes
Uploaded via twine/7.0.0 CPython/3.13.14

Provenance

Provenance describes where a file came from. On PyPI, provenance is shared via attestations, which provide a verifiable record of the build or publishing details. View details, limitations and caveats.

PyPI Publish Attestation

PyPI verified that this artifact, at this checksum, originated from the publisher listed below.

Signed by GitHub Actions, verified by PyPI on Oct 12, 2026.

Transparency log

Release history Release notifications | RSS feed

This release

1.1.3 This release

2 release files

1.1.2

2 release files

1.1.1

2 release files

1.1.0

2 release files

1.0.5

2 release files

1.0.4

2 release files

1.0.3

2 release files

1.0.2

2 release files

1.0.1

2 release files

0.1.0

2 release files

Anthropic, PBC Visionary sponsor Bloomberg Visionary sponsor Hudson River Trading Visionary sponsor Meta Visionary sponsor NVIDIA Visionary sponsor Microsoft Sustainability sponsor Depot Continuous Integration AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page