Method requestSkillShellPermission

agent/loop.go:902–935

(ctx context.Context, executor *StreamingToolExecutor, req skills.SkillShellPermissionRequest)

			}
		}
		if IsFatalAPIError(msg) {
			e.rememberAPIError(state, msg)
			ev := NewStreamEvent("error", msg, metadata)
			e.LastState = state
			return StreamAction{Return: true, Event: &ev, ConsecutiveAPIErrors: consecutiveAPIErrors}
		}
		if IsPTLErrorMessage(msg) && !IsFatalAPIError(msg) {
			turn.PTLDetected = true
			turn.PTLErrorMsg = msg
			return StreamAction{Break: true, ConsecutiveAPIErrors: consecutiveAPIErrors}
		}
		turn.StreamHadError = true
		consecutiveAPIErrors++
		if ShouldCommitFinalTextAfterStreamError(turn) {
			return StreamAction{Break: true, ConsecutiveAPIErrors: consecutiveAPIErrors}
		}
		e.rememberAPIError(state, msg)
		ev := NewStreamEvent("error", msg, metadata)
		if consecutiveAPIErrors >= MaxAPIErrorRetries {
			e.LastState = state
			return StreamAction{Return: true, Event: &ev, ConsecutiveAPIErrors: consecutiveAPIErrors}
		}
		metadata["recovered"] = true
		ev.Metadata = metadata
		return StreamAction{Break: true, Event: &ev, ConsecutiveAPIErrors: consecutiveAPIErrors}
	}
	return StreamAction{ConsecutiveAPIErrors: consecutiveAPIErrors}
}

func (e *CoreExecutionEngine) executeAndCommitTools(ctx context.Context, state *AgentState, executor *StreamingToolExecutor, out chan<- StreamEvent) {
	var toolResults []map[string]any
	for executor.HasPendingWork() {
		for _, event := range e.drainSkillPermissionEvents() {
			sendStream(ctx, out, event)
		}
		for _, progress := range executor.DrainProgress() {
			sendStream(ctx, out, BuildProgressEvent(progress))