diff --git a/crates/arc-workflows/src/cli/backend.rs b/crates/arc-workflows/src/cli/backend.rs index cf8fb483c..cde8eba43 100644 --- a/crates/arc-workflows/src/cli/backend.rs +++ b/crates/arc-workflows/src/cli/backend.rs @@ -43,6 +43,9 @@ fn spawn_event_forwarder( let mut rx = session.subscribe(); tokio::spawn(async move { while let Ok(event) = rx.recv().await { + // Reset watchdog on every event, including streaming deltas + emitter.touch(); + // Track file changes from tool calls match &event.event { AgentEvent::ToolCallStarted {