Agent Worker

Temporal runtime. NewAgentWorker and DisableLocalWorker apply to the Temporal runtime. For Restate durability labs, see Durable Agent (Restate).

Minimal agent + worker split: worker polls the task queue; agent process starts runs with DisableLocalWorker. Source: examples/agent_with_worker/

What it demonstrates

NewAgentWorker with the same options as NewAgent
DisableLocalWorker on the client process
Stream from the remote agent process
Foundation pattern for production distributed agents

Run

From examples/ with Temporal running:

task infra:temporal:up && task infra:temporal:wait

# Terminal 1
AGENT_RUNTIME=temporal go run ./agent_with_worker/worker

# Terminal 2
AGENT_RUNTIME=temporal go run ./agent_with_worker/agent "Hello from remote agent!"

For interactive durability scenarios (kill/restart), see Durable Agent (Temporal).

Key code

worker/main.go — polls Temporal, executes workflows and activities:

w, err := agent.NewAgentWorker(
    agent.WithName("agent-worker"),
    agent.WithLLMClient(llmClient),
    temporal.WithTemporalConfig(temporalCfg),
)
w.Start()

agent/main.go — starts runs, consumes stream without a local worker:

a, err := agent.NewAgent(
    agent.WithName("agent-worker"),
    agent.WithLLMClient(llmClient),
    temporal.WithTemporalConfig(temporalCfg),
    agent.DisableLocalWorker(),
)
// runID is available synchronously — persist for GetAgentStream before consuming events.
agentStream, _ := a.Stream(ctx, prompt, nil)
runID := agentStream.ID()
eventCh, _ := agentStream.Events(ctx)
_ = runID
_ = eventCh

Both processes use identical agent options so the SDK fingerprint matches.

Expected output

Terminal 1 (worker) shows Temporal polling logs at LOG_LEVEL=info. Terminal 2 (agent) prints the streamed reply:

Hello from remote agent! I'm running as a Temporal workflow on a separate worker process.

See Distributed Execution and Temporal Runtime for production context.

Learn more

Distributed Execution

Production split-process guide

Durable Agent (Temporal)

Advanced durability scenarios

Before You Begin

Basic Agents

Configuration

Tools & MCP

Streaming & AG-UI

Memory & RAG

Observability & Hooks

A2A

Multi-agent

Durable & Distributed

What it demonstrates

Run

Key code

Expected output

Learn more

Distributed Execution

Durable Agent (Temporal)

​What it demonstrates

​Run

​Key code

​Expected output

​Learn more

Distributed Execution

Durable Agent (Temporal)

What it demonstrates

Run

Key code

Expected output

Learn more