Optional Workshop reviews returning NO_REPLY after a rejected tool call were entering settled-turn finalization and making two extra provider requests. Restore the authored-silence guard using the current assistant classifier while retaining required-reply recovery and tool failure evidence. The focused optional-reply probe passes on9e9ea746f4and fails onf2dff0dcf9(#152786), which removed the original guard. The unchanged Workshop E2E reproduced five requests instead of three in all three main runs and passes all six scenarios in three patched runs. Validation on Linux: 75 recovery tests, 272 Workshop sibling tests, core typecheck, targeted lint, formatting, docs MDX, and independent review. The changed four-test file takes 14.24s wall with one worker; the new case runs in 3ms. Patched E2E runs take 85.72s, 85.60s, and 86.15s Vitest time. No security, protocol, schema, or permission contract changes.
32 KiB
| summary | read_when | title | ||
|---|---|---|---|---|
| Agent loop lifecycle, streams, and wait semantics |
|
Agent loop |
The agent loop is the serialized, per-session run that turns a message into actions and a reply: intake, context assembly, model inference, tool execution, streaming, persistence.
Entry points
- Gateway RPC:
agentandagent.wait. - CLI:
openclaw agent.
Run sequence
agentRPC validates params, resolves the session (sessionKey/sessionId), persists session metadata, and returns{ runId, acceptedAt }immediately.agentCommandruns the turn: resolves model + thinking/verbose/trace defaults, loads the skills snapshot, callsrunEmbeddedAgent, and emits a fallback lifecycle end/error if the embedded loop did not already emit one.runEmbeddedAgent: serializes runs via per-session and global queues, resolves model + auth profile, builds the OpenClaw session, subscribes to runtime events, streams assistant/tool deltas, enforces the run timeout (aborting on expiry), and returns payloads plus usage metadata. For Codex app-server turns, native Codex owns provider liveness and the exactturn/completedoutcome; quiet periods and assistant output do not end the turn.subscribeEmbeddedAgentSessionbridges runtime events to theagentstream: tool events tostream: "tool", assistant deltas tostream: "assistant", lifecycle events tostream: "lifecycle"(phase: "start" | "finishing" | "end" | "error").agent.waitwaits for the terminal outcome on arunIdand returns{ status: ok|error|timeout, startedAt, endedAt, error? }. Gateway RPC runs also wait for their terminal replay payload to be published, so a duplicate request after a terminal wait result can replay that outcome.
For embedded OpenAI Responses turns, response.completed finishes one model
response. If the provider sends end_turn: false, the loop requests another
response even when the completed response contains only text. Existing
cancellation, host stop decisions, and intentional tool termination still apply.
Each completed or incomplete Responses response also carries an
openai_responses_terminal entry in the saved assistant message's diagnostics.
It records eventType and the provider's endTurn signal as
true, false, "absent", or "invalid", without retaining malformed values.
Read it alongside the message's stopReason and text phase. These per-response
facts survive later responses in the same run and require no
raw-stream logging. They record the provider signal, not whether a host stop or
cancellation prevented continuation. Older messages without this diagnostic
cannot establish whether the provider omitted the signal.
The wait result also carries the run's terminalReply and, when available,
terminalReceipt. A receipt with sourceReplyDelivered: true confirms a final
reply reached the external source conversation. A2A announcements consume that
fact instead of using display-history mirrors as delivery evidence.
Queueing and concurrency
Runs are serialized per session key (session lane) and optionally through a global lane, preventing tool/session races. Messaging channels choose a queue mode (steer/followup/collect/interrupt) that feeds this lane system; see Command Queue.
Before streaming, an admitted run records its durable activeWriterRunId claim. Every transcript append or rewrite supplies expectedWriterRunId, and the synchronous commit transaction verifies that it still matches the active claim. A superseded run therefore cannot commit stale transcript data. The SQLite writer queue orders per-agent mutations, while the Gateway state-directory lock prevents another Gateway or openclaw agent --local process from owning the same state directory concurrently.
Session and workspace preparation
- Workspace is resolved and created; sandboxed runs may redirect to a sandbox workspace root.
- Skills are loaded (or reused from a snapshot) and injected into env and prompt.
- Bootstrap/context files are resolved and injected into the system prompt.
- The session transcript target and writer claim are prepared before streaming starts. Later rewrites, compaction, and truncation use the same in-transaction writer-claim fence.
Prompt assembly
System prompt is built from OpenClaw's base prompt, skills prompt, bootstrap context, and per-run overrides. Model-specific limits and compaction reserve tokens are enforced. See System prompt for what the model sees.
Hooks
OpenClaw has two in-process hook systems:
- Internal hooks:
HOOK.mdscripts for command and lifecycle events such ascommand:new. - Plugin hooks: typed
api.on(...)handlers inside the agent/tool lifecycle and Gateway pipeline, such asbefore_tool_call.
HTTP webhooks are separate: they accept external requests that trigger work, rather than subscribing to agent-loop events.
Internal hooks (Gateway hooks)
agent:bootstrap: runs while building bootstrap files before the system prompt is finalized. Use it to add or remove bootstrap context files.- Command hooks: core emits
command:new,command:reset, andcommand:stop. Other command names do not automatically become hook events.
See Hooks for setup and examples.
Plugin hooks
These run inside the agent loop or gateway pipeline:
| Hook | Runs |
|---|---|
before_model_resolve |
Pre-session (no messages), to deterministically override provider/model before resolution. |
before_prompt_build |
After session load (with messages), to inject prependContext, systemPrompt, prependSystemContext, or appendSystemContext, or, on supported runtimes with a turn-scoped submitted tool surface, narrow it with toolsAllow. An empty toolsAllow submits no optional tools; omitted leaves the host-resolved surface unchanged. Unsupported runtimes reject restrictive values instead of ignoring them. |
before_agent_reply |
After inline actions, before the LLM call. Lets a plugin claim the turn and return a synthetic reply or silence it entirely. |
agent_end |
After completion, with the final message list and run metadata. |
before_compaction / after_compaction |
Observe compaction cycles; these hooks do not rewrite or veto compaction. |
before_tool_call / after_tool_call |
Intercept tool params/results. |
before_install |
After operator install policy runs, on staged skill/plugin install material, when plugin hooks are loaded in the current process. |
tool_result_persist |
Synchronously transforms tool results before they are written to an OpenClaw-owned session transcript. |
message_received / message_sending / message_sent |
Inbound and outbound message hooks. |
session_start / session_end |
Session lifecycle boundaries. |
gateway_start / gateway_stop |
Gateway lifecycle events. |
Hook decision rules for outbound/tool guards:
before_tool_call:{ block: true }is terminal and stops lower-priority handlers.{ block: false }is a no-op and does not clear a prior block.before_install: same terminal/no-op semantics as above. Usesecurity.installPolicy, notbefore_install, for operator-owned install allow/warn/block decisions that must cover CLI install and update paths.message_sending:{ cancel: true }is terminal and stops lower-priority handlers.{ cancel: false }is a no-op and does not clear a prior cancel.
See Plugin hooks for the hook API and registration details.
Harnesses can adapt these hooks. The Codex app-server harness keeps OpenClaw plugin hooks as the compatibility contract for documented mirrored surfaces; Codex native hooks are a separate, lower-level Codex mechanism.
Streaming
- Assistant deltas stream from the agent runtime as
assistantevents. - Adjacent text appends already waiting in the provider event queue can merge before agent delivery. This adds no buffering delay; snapshots, content-block changes, reasoning, tools, and terminal events remain separate boundaries.
- Block streaming can emit partial replies on
text_endormessage_end. - Reasoning streaming can be a separate stream or block replies.
- See Streaming for chunking and block reply behavior.
Tool execution
- Tool start/update/end events emit on the
toolstream. - Tool results are sanitized for size and image payloads before logging/emitting.
- Messaging tool sends are tracked to suppress duplicate assistant confirmations.
Reply shaping
Final payloads are assembled from assistant text (plus optional reasoning), inline tool summaries (when verbose and allowed), and assistant error text when the model errors.
- The exact silent token
NO_REPLYis filtered from outgoing payloads. - Messaging tool duplicates are removed from the final payload list.
- A fallback tool error warning appears only when a run ends with a tool failure and would otherwise leave the user with no reply. This guard is not configurable; a user-facing reply, including one already delivered by a messaging tool, prevents the warning.
The host decides whether an input requires a visible reply. Direct requests and accepted group/channel requests require an answer by default. Unaddressed group requests remain optional only when the operator explicitly allows the silence policy; mentions and authorized commands still require a response. Ambient room events and internal helper turns remain optional. Model-authored NO_REPLY is empty output, not permission to waive a required response; required turns with no delivered reply still need an answer.
If a required-reply turn ends after a fully settled tool batch without a composed answer, OpenClaw can make a tool-free finalization pass. Earlier tool errors, pre-tool progress, and superseded, undelivered confirmations do not count as a final answer. This pass uses the settled results and does not repeat completed tools. Fatal automation failures, including denied execution, remain failures even when finalization produces an answer.
An optional turn that explicitly finishes with NO_REPLY does not need a finalization pass, even after a settled tool failure. The failure remains recorded; a rejected Skill Workshop review still fails without making extra model requests to compose a reply.
A confirmed delivery prevents duplicate generation. Pending delivery or continuation work retains completion ownership without being marked delivered; rejected sends, unflushed deferred text, and missing delivery callbacks are not delivery proof. NO_REPLY does not retract text already delivered. Pending tools, accepted child runs, and yielded work keep their existing owners, and assistant errors and aborts are not intentional silence.
Prompt-segment diagnostics attribute attachment/context blocks and generated inbound metadata separately from user text. A prompt containing only those blocks does not need trailing user text for reply processing to complete.
Compaction and retries
When an OpenAI Responses request hits its output limit while generating a tool call, the built-in harness finishes already admitted tools and retries from their recorded results. The unfinished call never executes. Recovery uses the existing bounded session retry budget and remains cancellable; refusals and inconsistent terminal responses do not qualify for this continuation.
Auto-compaction emits compaction stream events and can trigger a retry. On retry, in-memory buffers and tool summaries reset to avoid duplicate output. See Compaction.
Event streams
lifecycle: emitted bysubscribeEmbeddedAgentSession(and as a fallback byagentCommand).assistant: streamed deltas from the agent runtime.tool: streamed tool events from the agent runtime.
The Gateway projects lifecycle and tool start/terminal events into the bounded, metadata-only audit ledger. This projection records provenance and result codes without copying prompts, messages, tool arguments, tool results, or raw errors out of the transcript/runtime path.
Chat channel handling
Assistant deltas buffer into chat delta messages. Terminal lifecycle events
produce chat final, error, or aborted messages. Definitive cancellation and
timeout events finalize immediately, including when the runtime reports them as
phase: "error". Retryable errors keep a 15-second grace window for a fallback
or restart of the same run. Once the outer execution owner has finished its
attempts, it publishes executionSettled: true. The Gateway consumes that fact
without retry grace, including preparation failures that never reached a model
or emitted a fallback step. For Gateway RPC runs, agent.wait also joins terminal
replay publication after required settlement. Unmarked timeout and bare-abort observations
retain their existing wait-layer retry handling.
Cron attempt completions remain finishing across model fallbacks and
interim-acknowledgment retries; worker finishing events do not claim execution
settlement. Completed execution facts are captured before cron bookkeeping, but
finality is published only after execution settles. A new attempt clears the
prior outcome before preparation. Later workflow errors or aborts cannot
reclassify completed execution; cron persistence, delivery, and yielded-parent
continuation retain their separate outcomes.
History keeps a run active while its terminal session write is pending. Once that write succeeds, history and session activity show the recorded end time and duration without waiting for retry grace.
Live snapshots are scoped to their assistant message. A correction can shorten or clear the current preview without erasing earlier messages. Pending text is flushed before the terminal event; pacing live updates does not delay tool execution or transcript writes.
Run-duration metadata belongs to the current run, including when preparation fails before the model starts. In Control UI completed-work rollups, independent sends have separate elapsed-time boundaries: a failed turn and the idle time before the next send are not part of that next turn's work. Steering remains associated with its target run rather than being treated as an independent retry.
Timeouts
When no result is available before an agent.wait deadline, the response contains
only runId and status: "timeout".
It does not cancel the run or identify its execution phase; wait on the same
runId again to observe completion. A wait interrupted by Gateway lifecycle
shutdown includes timeoutPhase: "gateway_draining" without terminal metadata.
Known queued chat turns report status: "pending", timeoutPhase: "queue", and
providerStarted: false.
| Timeout | Default | Notes |
|---|---|---|
agent.wait |
30s | Wait-only; timeoutMs param overrides. Does not stop the underlying run. |
Agent runtime (agents.defaults.timeoutSeconds) |
172800s (48h) | Elapsed execution budget, aborting on expiry. Progress does not reset it. Set 0 for unlimited execution; runtime-owned provider liveness still applies. Codex enforces this budget per attempt, independently of its native stream recovery. |
| CLI backend no-output watchdog | computed per fresh/resumed CLI run | Separate from the agent runtime and owned by the registered backend plugin. A CLI-internal background task shares the parent subprocess and does not outlive an overall agent timeout. |
| Cron isolated agent turn | owned by cron | The scheduler starts its own timer when execution begins, aborts the run at the configured deadline, then runs bounded cleanup before recording the timeout so a stale child session cannot keep the lane stuck. |
| Model idle timeout | Cloud 120s; self-hosted 300s | OpenClaw aborts a model request when no response chunks arrive before the idle window. models.providers.<id>.timeoutSeconds extends this idle watchdog for slow local/self-hosted providers, but stays bounded by any lower finite agents.defaults.timeoutSeconds or run-specific timeout, since those govern the whole agent run. Unlimited run budgets still keep the provider-class idle watchdog. Cron-triggered cloud model runs with no explicit model/agent timeout use the same default; with an explicit cron run timeout, cloud model stream stalls cap at 60s so configured model fallbacks can still run before the outer cron deadline. Cron-triggered runs on genuinely local endpoints (loopback/private baseUrl) keep the local idle opt-out; self-hosted providers on network baseUrls get the 300s implicit watchdog. With an explicit cron run timeout, local/self-hosted stalls cap at that timeout. Set models.providers.<id>.timeoutSeconds for slow local providers. |
| Provider HTTP request timeout | models.providers.<id>.timeoutSeconds |
Covers connect, headers, body, SDK request timeout, guarded-fetch abort handling, and the model stream idle watchdog for that provider. Use for slow local/self-hosted providers (for example Ollama) before raising the whole agent runtime timeout; keep the agent/runtime timeout at least as high when the model request needs to run longer. |
The built-in OpenClaw harness publishes its execution deadline to the queue.
Approval waits pause the unused budget; resolving all pending approvals resumes
that same budget. Compaction can receive one bounded grace period. A question
from ask_user does not pause the overall execution budget. With 0, no
execution timer is armed, but provider liveness, Stop, and bounded abort cleanup
still apply. Isolated post-tool finalization gets its own deadline and cancellation
controls rather than inheriting callbacks from the completed attempt.
A terminal timeout is a failed turn, not a successful completion. Chat and command results retain its timeout explanation; earlier tool errors do not replace that explanation or restart an already-final timed-out turn.
The model idle and provider HTTP rows describe the built-in OpenClaw model path. Codex owns its native stream deadlines and network retries. After exact native terminal receipt, OpenClaw allows two minutes for local settlement. After separately bounded abort cleanup, queued projection gets a five-second drain grace. Neither window resets on progress. These cleanup limits still apply when the execution budget is unlimited. See Codex timeouts.
When a runtime reports a definitive timeout, the Gateway records its terminal status and error for the session sidebar immediately, without waiting for provider retry grace. Opening the failed session dismisses its sidebar attention as usual. A later successful turn clears the previous error and is not replaced by an older delayed failure.
Stuck session diagnostics
With diagnostics enabled, a built-in two-minute threshold classifies long processing sessions with no observed reply, tool, status, block, or ACP progress:
- Active embedded runs, model calls, and tool calls report as
session.long_running. Owned silent model calls staysession.long_runninguntil the abort threshold so slow or non-streaming providers are not flagged as stalled too early. - Active work with no recent progress reports as
session.stalled. Owned model calls switch tosession.stalledat or after the abort threshold; ownerless stale model/tool activity is not hidden as long-running. session.stuckis reserved for recoverable stale session bookkeeping, including idle queued sessions with stale ownerless model/tool activity.
The abort threshold is at least 5 minutes and 3x the warning threshold. Stale session bookkeeping releases the affected session lane immediately after recovery gates pass; stalled embedded runs are abort-drained only after the abort threshold, so queued work resumes without cutting off merely slow runs. Recovery emits structured requested/completed outcomes; diagnostic state is marked idle only if the same processing generation is still current, and repeated session.stuck diagnostics back off while the session stays unchanged.
Attention and recovery log lines read optional session context only when their log level is enabled. Transcript enrichment runs in the background read worker and returns at most 140 characters; it never delays classification or recovery. Session replacement discards pending enrichment, and stopping diagnostics retires pending log publications. Incognito replies remain excluded.
Pending human-input questions protect their exact active owner from stale-work recovery. If checking a question expires it, or diagnostic reporting resumes or replaces the run, that observation cannot authorize an abort of the resumed work. Recovery revalidates the session generation captured with the observation.
A current Codex attempt waiting on native work is the exception to these idle
thresholds: it remains session.long_running with reason runtime_owned_wait
and is not aborted or taken over merely because it is quiet. Recovery and
steering revalidate that exact active owner and its execution budget. This does
not protect expired OpenClaw-owned requests or tools, cancellation, terminal
settlement, or ownerless state.
Where things can end early
- Agent timeout (abort)
- AbortSignal (cancel)
- Gateway disconnect or RPC timeout
agent.waittimeout (wait-only, does not stop the agent)
Related
- Tools - available agent tools
- Hooks - event-driven scripts triggered by agent lifecycle events
- Compaction - how long conversations are summarized
- Exec Approvals - approval gates for shell commands
- Thinking - thinking/reasoning level configuration
- Agent runtimes - alternate harness runtimes that drive this loop