Method enforceMaxIterations

pkg/runtime/loop_steps.go:48–112

enforceMaxIterations runs at the top of every loop iteration. When the iteration count has reached the limit, it emits MaxIterationsReached and drives the appropriate exit/resume flow: - non-interactive sessions auto-stop with an assistant message, - interactive sessions block on r.resumeChan until

(
	ctx context.Context,
	sess *session.Session,
	a *agent.Agent,
	iteration int,
	runtimeMaxIterations int,
	events EventSink,
)

// tests that pump the resume channel and assert the resulting events
// without standing up a full model + toolset pipeline.
func (r *LocalRuntime) enforceMaxIterations(
	ctx context.Context,
	sess *session.Session,
	a *agent.Agent,
	iteration int,
	runtimeMaxIterations int,
	events EventSink,
) (newMax int, decision iterationDecision) {
	if runtimeMaxIterations <= 0 || iteration < runtimeMaxIterations {
		return runtimeMaxIterations, iterationContinue
	}

	slog.DebugContext(ctx, "Maximum iterations reached",
		"agent", a.Name(),
		"iterations", iteration,
		"max", runtimeMaxIterations,
	)

	events.Emit(MaxIterationsReached(runtimeMaxIterations))

	maxIterMsg := fmt.Sprintf("Maximum iterations reached (%d)", runtimeMaxIterations)
	r.notifyMaxIterations(ctx, a, sess.ID, maxIterMsg)
	r.executeOnUserInputHooks(ctx, sess.ID, "max iterations reached")

	stopMsg := fmt.Sprintf(
		"Execution stopped after reaching the configured max_iterations limit (%d).",
		runtimeMaxIterations,
	)
	appendStopMsg := func() {
		addAgentMessage(sess, a, &chat.Message{
			Role:      chat.MessageRoleAssistant,
			Content:   stopMsg,
			CreatedAt: r.now().Format(time.RFC3339),
		}, events)
	}

	// In non-interactive mode (e.g. MCP server), auto-stop instead of
	// blocking forever waiting for user input.
	if sess.NonInteractive {
		slog.DebugContext(ctx, "Auto-stopping after max iterations (non-interactive)", "agent", a.Name())
		appendStopMsg()
		return runtimeMaxIterations, iterationStop
	}

	// Wait for user decision (resume / reject)
	select {
	case req := <-r.resumeChan:
		if req.Type == ResumeTypeApprove {
			slog.DebugContext(ctx, "User chose to continue after max iterations", "agent", a.Name())
			newMax := iteration + 10
			r.executeOnSessionResumeHooks(ctx, a, sess.ID, runtimeMaxIterations, newMax)
			return newMax, iterationContinue
		}
		slog.DebugContext(ctx, "User rejected continuation", "agent", a.Name())
		appendStopMsg()
		return runtimeMaxIterations, iterationStop

	case <-ctx.Done():