Durable Agent (Restate)

The durable_agent/restate example is an interactive Restate lab. One process embeds the Restate SDK endpoint. Kill the agent mid-stream, keep Restate running, restart, and reconnect with GetAgentStream + WithOffset. Use it after Restate runtime when you need to feel Restate durability. For the Temporal split worker/agent lab, see Durable Agent (Temporal). Source: examples/durable_agent/restate/

Step-by-step exercises: examples/durable_agent/restate/README.md.

Architecture

Process	Entry	SDK pattern
Agent	`durable_agent/restate`	`NewAgent` + `restate.WithRestateConfig` — embedded SDK endpoint
Restate server	`task infra:restate:up`	Ingress + journal; calls back into the endpoint

Streaming and reconnect use the same public APIs as Temporal (GetAgentStream + WithOffset, GetAgentRun). State file: /tmp/durable_agent_restate_runstate.json.

Before you start

From examples/, after Configuration:

AGENT_RUNTIME=restate
RESTATE_INGRESS_URL=http://localhost:8080
RESTATE_ADMIN_URL=http://localhost:9070
RESTATE_ENDPOINT_LISTEN_ADDRESS=:9080
# RESTATE_DEPLOYMENT_URL=http://host.docker.internal:9080  # if Restate is in Docker

task infra:restate:up && task infra:restate:wait
go run ./durable_agent/restate

Admin UI: http://localhost:9070. Full local notes: restate-setup.md.

Durability scenarios

Scenario	What to try	What you learn
1. Happy path	REPL + short prompt	End-to-end Restate stream
2. Kill mid-stream	`pkill` during a long prompt; restart; answer `y` to reconnect	`GetAgentStream` + `WithOffset` while invocation is live
3. Graceful Ctrl+C	Stop and restart while Restate still has the run	Same reconnect path
4. Already finished	Restart after completion	`ErrRunAlreadyCompleted` — start a new turn
5. Restate down	Stop Restate, run agent	Clear connect/start failure
6. Docker callback	Set `RESTATE_DEPLOYMENT_URL`	Host endpoint reachable from containerized Restate

Full steps: README. Protocol details: Durable Execution.

Learn more

Durable Execution

Shared reconnect protocol (Temporal and Restate)

Restate Runtime

Ingress, embedded endpoint, streaming

Durable Agent (Temporal)

Split worker/agent crash lab

Reconnect Example

Focused GetAgentStream demo (Temporal binary)

Before You Begin

Basic Agents

Configuration

Tools & MCP

Streaming & AG-UI

Memory & RAG

Observability & Hooks

A2A

Multi-agent

Durable & Distributed

Architecture

Before you start

Durability scenarios

Learn more

Durable Execution

Restate Runtime

Durable Agent (Temporal)

Reconnect Example

​Architecture

​Before you start

​Durability scenarios

​Learn more

Durable Execution

Restate Runtime

Durable Agent (Temporal)

Reconnect Example

Architecture

Before you start

Durability scenarios

Learn more