Skip to content

Idempotency

Tulip deduplicates identical tool calls within a documented execution scope.

The model may retry. With idempotent=True, an identical call later in the same agent.run() reuses the recorded result instead of invoking the tool body again. When agent.run(..., thread_id=...) reloads a checkpointed thread, that recorded result can also prevent a replay. A run continued with agent.resume() does not check for a prior match; see How it works.

If you ever plan to run an agent that refunds, deploys, pages, emails, or writes, this is the most important single page on the docs site.

When to use idempotent=True

Situation idempotent=True?
Side-effecting tool with real-world cost (issue a refund, ship a deploy, page on-call) Usually yes, plus a downstream idempotency key
Database write you can't trivially roll back yes
External service that's already idempotent on its end yes — the SDK dedupes the round-trip too
Read-only order lookup no — re-reads are cheap, leave it to the model
Tool that intentionally generates a new entity each call (e.g. mint_case_id) no — that breaks the contract

How it works

Inside a single agent run, the SDK hashes the tool's (name, arguments) tuple as the model emits each call. The first call with a given key hits the function body and the result is recorded. A later call with the same key in the run() loop short-circuits to the cached response without invoking the body (exceptions below).

from tulip.tools import tool
@tool(idempotent=True)
def issue_refund(order_id: str, amount: float) -> dict:
    """Refund an order. Re-fires within a run return the cached receipt."""
    return billing.refund(order_id, amount)

The argument hash is the trust boundary:

  • Same call: the model re-emits issue_refund("ord-4821", 120.0) after seeing the receipt → cache hit, body skipped.
  • Different call: the model emits issue_refund("ord-4822", 120.0) → different key, body runs.

Dedup compares the arguments as they reach the tool — the dict the model emitted, after any on_before_tool_call hooks have run. A call from an earlier turn is matched with a plain dict == dict equality on (tool_name, arguments); a duplicate inside the same model response is matched on a sorted-key JSON serialisation of the arguments. The two agree for ordinary arguments, but not on number type: 120 and 120.0 match across turns, not within one response. Both checks run in the run() loop, including a run that reloads a checkpointed thread with thread_id. They do not run after agent.resume() answers an interrupt: the continued run executes each tool call without looking for a prior match, so an identical idempotent call runs the body again. A held call that resume(perform_dangling=True) runs is not recorded in tool_executions at all, so no later call can match it. Both sides of the comparison are normally post-hook: each call the loop runs, or serves from the cache, is recorded with the hook-modified arguments, so a before-hook that normalises arguments (for example, upper-casing an order id) makes a new call and its earlier twin agree. A call a hook cancels is recorded with the arguments the model emitted, so for an idempotent tool a later identical call can match that cancelled record and return its cancel message without running the body. A hook only affects calls made after it is installed; it does not retroactively match executions already recorded with un-normalised arguments. Without such a hook there is no schema normalization: defaults are not filled in before the comparison, so a call that omits an optional argument and a call that passes that argument's default value are treated as different keys and both fire the body. (Dict equality is itself order-independent, so key order alone won't break a match.)

Why this matters

Actions with real-world cost

The model that calls issue_refund twice in one run is more common than you think. Sometimes it sees an ambiguous tool result and tries again "to be sure". Sometimes the network glitches and the model believes the call failed. Without idempotency, the customer is refunded twice and finance opens a ticket for the duplicate.

@tool(idempotent=True)
def issue_refund(order_id: str, amount: float) -> dict:
    return billing.refund(order_id, amount)

Within the active run, an identical second call reuses the first result. The same mechanism applies to a deploy (deploy_service), a page (page_oncall), and the security-operations variant (isolate_host).

Outbound side-effects

page_oncall, open_case, slack_alert, block_indicator — anything that touches a human or a downstream system. One and done.

Database writes you can't roll back

Insert into an audit table, append to a Kafka topic, sign a JWT — operations where retrying isn't free. Idempotent tools reduce duplicate calls inside the agent runtime; they do not create distributed exactly-once delivery.

Replays after checkpoint resume

When agent.run(..., thread_id=...) reloads a checkpointed thread, the model may decide to re-issue tool calls it's already seen. Idempotent tools see the cache pre-populated from the checkpoint and skip the side effect on replay. (This requires tool_executions to be restored from the checkpoint; the SDK's native checkpointers handle it.)

What it is not

Concept Idempotency is… Idempotency is not…
Scope within a single agent run cross-run — restart and the cache is gone (use a checkpointer)
Failure one fire per identical call in the run() loop retry — if the body raises, the exception propagates as the cached "result"
Boundary per-agent network — two different agents both calling issue_refund(o, a) each fire once

If you need cross-run idempotency, configure a checkpointer and an idempotent server-side endpoint. Generate a stable operation key from the business operation (for example, refund:ORD-4821:v1) and send it to that endpoint on every attempt.

The external-success crash window

There is an unavoidable boundary between two systems:

  1. the payment, deploy, or message succeeds in the external service;
  2. the process stops before Tulip durably records the returned receipt;
  3. the run resumes and cannot prove locally that the external call succeeded;
  4. the call may be attempted again.

An in-memory cache cannot close that window. A checkpointer narrows it, but the downstream system must recognize the same stable idempotency key and return the original result rather than repeat the operation. Treat idempotent=True as agent-loop deduplication and downstream keys as distributed-operation safety.

Practical recipe — refund approval

A canonical multi-agent idempotency shape: an agent (or three of them, debating) loops over a refund decision, then writes once.

@tool(idempotent=True)
def issue_refund(order_id: str, amount: float) -> dict:
    return billing.refund(order_id, amount)

@tool(idempotent=True)
def page_oncall(case_id: str, summary: str) -> str:
    return pager.notify(team="support", subject=f"CASE {case_id}", body=summary)

The agent can iterate while reasoning about whether to refund. Repeated calls with identical arguments reuse the cached result in the supported scope. For a real payment or page, the tool body should also pass a stable idempotency key to the provider.

Common gotchas

Symptom Likely cause
Tool re-fires despite idempotent=True Argument changed between calls. Check that the model isn't mutating order ids / amounts between turns.
Idempotent cache survives across runs unexpectedly It shouldn't — only the checkpointer persists state. If you're seeing this, you're loading state from a checkpoint and don't want to.
Body raised first time, cache returns the exception This is by design — the failure is part of the "result" of the first call. The model sees the failure and can react. To re-attempt, the model must change an argument.
Read-only lookup tagged idempotent=True Harmless but wasteful — the cache hit savings are negligible vs the read itself. Leave it off.

Source and notebook

See also

  • Tools — the full @tool decorator surface.
  • Checkpointers — durable runs where idempotency interacts with replay.