async fn observe_owned_run(
store: &AgentTaskStore,
options: &AgentWorkerOptions,
claim: &AgentTaskClaim,
runs: &AgentRunStore,
workspace_root: &Path,
run_id: &str,
shutdown: &mut Receiver<bool>,
) -> Result<()>async fn observe_owned_run(
store: &AgentTaskStore,
options: &AgentWorkerOptions,
claim: &AgentTaskClaim,
runs: &AgentRunStore,
workspace_root: &Path,
run_id: &str,
shutdown: &mut Receiver<bool>,
) -> Result<()>