agent

Overview ¶

Interactive streaming REPL for the durable_agent example.

Usage:

go run . [initial prompt]

Streams events delivered via Temporal Workflow Streams, so each run has a durable event log hosted in the Temporal server. Kill the worker or this process mid-run, then restart to observe workflow replay and recovery.

GetAgentStream support: on startup the agent checks for a saved run state (runID + last offset) in /tmp/durable_agent_runstate.json. If one exists it asks whether to reconnect from the last known offset. This demonstrates the full crash-and-recover cycle without any extra infrastructure.

At the "you>" prompt type any message. Approval requests pause the stream and ask for y/n before continuing. Type "exit" or "quit" to stop.