ci: add first-agent CLI wayfinding target

.github/loop/PRIORITIES.md

@@ -21,8 +21,9 @@ changes, architectural rewrites. Those go to the human.
 
 ## Work queue (ranked)
 
-1. **Fix AtlasCloud plan-delegate incomplete delegate tool call** ([#4487](https://github.com/micro/go-micro/issues/4487)) — The adoption-facing inner-loop contract is now shipped, and there are no open `codex` PRs in flight, so the top remaining gap returns to a Now-phase resilience failure in the lived services → agents → workflows story: AtlasCloud can create task side effects, then stop on an incomplete repaired `delegate` tool call before notification/delegation completes. This is higher value than a single marker wording failure because it protects the cross-runtime handoff after real side effects and keeps the 0→hero/plan-delegate harness operable across providers.
-2. **Fix AtlasCloud agent harness missing conformance marker** ([#4486](https://github.com/micro/go-micro/issues/4486)) — Once the delegate repair path is stable, close the remaining scheduled live-conformance gap where AtlasCloud's agent harness exhausts retries without emitting the required marker. This is still a Now-phase provider-conformance item, but narrower: it verifies the core agent/model+tool contract rather than the full services → agents → workflows handoff.
+1. **CI-verify first-agent CLI wayfinding commands** ([#4336](https://github.com/micro/go-micro/issues/4336)) — Developer adoption is the current goal, and the README/docs now steer new users through installed CLI affordances (`micro agent demo`, `micro examples`, `micro zero-to-hero`) before deeper tutorials. Those commands should be treated as a no-secret on-ramp contract so the binary keeps pointing developers to the maintained first-agent, debugging, examples, and 0→hero path instead of drifting silently.
+2. **Add durable checkpoint/resume for agent runs** ([#4341](https://github.com/micro/go-micro/issues/4341)) — With the plan/delegate recovery issue closed, the next biggest lifecycle seam is that flows can checkpoint and resume but long agent runs still need a durable recovery contract. Solving this keeps the services → agents → workflows story cohesive without replaying completed tool side effects, and it should stay scoped to a non-breaking, CI-verifiable harness increment.
+3. **Trace agent RunInfo in OpenTelemetry spans** ([#4315](https://github.com/micro/go-micro/issues/4315)) — Once the CLI on-ramp is protected and agent runs have a durable recovery path like flows, the highest Next-phase operability gap is connecting existing run metadata to traces so real agent runs can be debugged across steps, tool calls, delegation, failures, services, and flows without inventing a new surface.
 
 _Seeded by Claude Code from the roadmap + open issues; thereafter maintained by the
 architecture-review pass._

.github/workflows/loop-release.yml

@@ -1,11 +1,9 @@
 name: "Loop: Release"
 
-# Generated by `micro loop init`. Cuts the next tag when the default branch has
-# new commits since the latest one, and pushes it with a PAT (CODEX_TRIGGER_TOKEN)
-# so any tag-triggered release workflow fires. The bump reflects what shipped,
-# read from the CHANGELOG [Unreleased] section: new features (Added/Changed) cut
-# a MINOR; fixes/docs only cut a PATCH; breaking changes are skipped so a MAJOR
-# stays a human decision.
+# Generated by `micro loop init`. Cuts the next PATCH tag
+# (vMAJOR.MINOR.PATCH+1) when the default branch has new commits
+# since the latest such tag, and pushes it with a PAT (CODEX_TRIGGER_TOKEN) so any
+# tag-triggered release workflow fires. Minor/major bumps stay with a human.
 #
 # The tag MUST be pushed with a PAT, not the default GITHUB_TOKEN: a tag pushed
 # by GITHUB_TOKEN does not trigger other workflows (Actions blocks that recursion).
@@ -68,30 +66,11 @@ jobs:
             [0-9]*.[0-9]*.[0-9]*) ;;
             *) echo "unexpected tag shape: $LATEST" ; exit 1 ;;
           esac
-
-          # Choose the bump from what actually shipped, read from the CHANGELOG
-          # [Unreleased] section (kept current by the coherence role):
-          #   new features (### Added / ### Changed) -> MINOR
-          #   fixes/docs only                        -> PATCH
-          #   breaking (### Removed / "(breaking)")  -> skip; a major is a human call
-          UNRELEASED=""
-          if [ -f CHANGELOG.md ]; then
-            UNRELEASED=$(awk '/^## \[Unreleased\]/{f=1; next} /^## \[/{f=0} f' CHANGELOG.md)
-          fi
-          if printf '%s\n' "$UNRELEASED" | grep -qiE '^### Removed|^### Changed \(breaking\)|BREAKING'; then
-            echo "CHANGELOG [Unreleased] contains breaking changes — a major release is a human decision. Skipping."
-            exit 0
-          elif printf '%s\n' "$UNRELEASED" | grep -qE '^### (Added|Changed)'; then
-            NEXT="v${major}.$((minor + 1)).0"
-            KIND="minor (new features)"
-          else
-            NEXT="v${major}.${minor}.$((patch + 1))"
-            KIND="patch (fixes/docs only)"
-          fi
-          echo "cutting: $NEXT — $KIND ($COUNT commits since $LATEST)"
+          NEXT="v${major}.${minor}.$((patch + 1))"
+          echo "cutting: $NEXT ($COUNT commits since $LATEST)"
 
           git config user.name "loop release bot"
           git config user.email "noreply@users.noreply.github.com"
-          git tag -a "$NEXT" -m "Release $NEXT — automated $KIND ($COUNT commits since $LATEST)"
+          git tag -a "$NEXT" -m "Release $NEXT — automated patch ($COUNT commits since $LATEST)"
           git push "https://x-access-token:${RELEASE_TOKEN}@github.com/${REPO}.git" "$NEXT"
           echo "Pushed $NEXT."

CHANGELOG.md

@@ -5,10 +5,9 @@ All notable changes to Go Micro are documented here.
 Format follows [Keep a Changelog](https://keepachangelog.com/) and versions
 follow [Semantic Versioning](https://semver.org/), matching the git tags and
 [GitHub releases](https://github.com/micro/go-micro/releases) (`v6.MINOR.PATCH`).
-Releases are cut automatically as the loop merges improvements — a **minor**
-bump when new features land (`### Added`/`### Changed`), a **patch** when it's
-fixes/docs only; major bumps stay a human decision. The `[Unreleased]` section
-below is kept current between tags and rolled into the next version when it ships.
+Patch releases are cut automatically as the loop merges improvements; the
+`[Unreleased]` section below is kept current between tags and rolled into the
+next version when it ships.
 
 > Earlier `2026.0x` headings are historical calendar-style markers from before
 > v6 tagging; they are kept for continuity and not reused.
@@ -17,41 +16,13 @@ below is kept current between tags and rolled into the next version when it ship
 
 ## [Unreleased]
 
-### Added
-- **Agent stream provider conformance** — provider conformance now covers agent streaming behavior so streaming-capable providers stay aligned with the harness contract. (`agent/`, `internal/harness/`)
-
-### Changed
-- **Provider model call timeouts** — model call timeout enforcement now wraps provider calls more defensively, reducing hangs in agent and harness paths. (`agent/`, `ai/`)
-- **First-agent harness diagnostics** — getting-started harness logs now make first-run and 0→hero failures easier to locate. (`internal/harness/`)
-
-### Fixed
-- **Partial text tool calls** — text tool-call recovery now repairs partial function-style calls more reliably before fallback parsing continues. (`agent/`)
-- **Retry timeout test stability** — retry timeout coverage is less race-prone. (`agent/`)
-- **Checkpointed tool-call resume** — resumed agent runs now preserve checkpointed tool calls across startup resume paths. (`agent/`)
-
-### Documentation
-- **Roadmap agent status** — public roadmap docs now reflect the current agent lifecycle status more consistently. (`internal/website/docs/`)
-- **Agent resume limits** — docs now describe checkpoint resume boundaries for agent runs. (`internal/website/docs/`)
-
----
-
-## [6.4.0] - July 2026
-
 ### Added
 - **Provider HTTP retry signals** — provider failures now preserve HTTP status and `Retry-After` details so retry classification and backoff can respond to rate limits and unavailable providers. (`ai/`)
-- **Zero-to-hero deploy dry-run verification** — the maintained 0→hero harness now covers deploy dry-run boundaries for the services → agents → workflows lifecycle. (`internal/harness/`)
-- **First-agent CLI wayfinding verification** — the harness now checks that first-agent CLI wayfinding stays discoverable. (`internal/harness/`)
-- **Agent startup resume verification** — agent startup resume now has focused checkpoint coverage. (`agent/`, `internal/harness/`)
-- **Direct first-agent chat prompts** — first-agent flows can accept direct chat prompts, reducing friction in the first useful conversation. (`cmd/micro/`, `agent/`)
-- **Workflow run info on tool spans** — agent tool spans now include workflow run details for easier trace correlation. (`agent/`, `flow/`)
 
 ### Fixed
 - **Stream fallback memory** — unsupported streaming attempts no longer leave stale duplicate user turns before fallback paths continue with non-streaming agent calls. (`agent/`)
 - **Function-style text tool calls** — agent fallback parsing now recognizes provider replies that render tools as function-style calls, including nested JSON arguments. (`agent/`)
 - **Plan/delegate notify recovery** — plan-delegate recovery now waits for recovered notify side effects and routes retries through the communications agent that owns the notification. (`internal/harness/`)
-- **Onboarding side-effect enforcement** — the agent-flow harness now fails when required onboarding side effects are missing, making lifecycle regressions visible. (`internal/harness/`)
-- **Plan/delegate notify stability** — notify recovery is more deterministic across retry and replay paths. (`agent/`, `internal/harness/`)
-- **AtlasCloud MiniMax tool fallback** — AtlasCloud MiniMax service-tool fallback now handles 400 responses and follow-up retries more reliably. (`ai/atlascloud/`, `agent/`)
 
 ### Documentation
 - **First-agent docs wayfinding guard** — the local harness now includes a focused no-network check for first-agent and 0→hero docs links. (`Makefile`, `internal/harness/`)

Makefile

@@ -8,7 +8,7 @@ LDFLAGS = -X $(GIT_IMPORT).BuildDate=$(BUILD_DATE) -X $(GIT_IMPORT).GitCommit=$(
 # GORELEASER_DOCKER_IMAGE = ghcr.io/goreleaser/goreleaser-cross:v1.25.7
 GORELEASER_DOCKER_IMAGE = ghcr.io/goreleaser/goreleaser:latest
 
-.PHONY: test test-race test-coverage harness inner-loop cli-wayfinding docs-wayfinding install-smoke provider-conformance-mock provider-conformance lint fmt install-tools proto clean help gorelease-dry-run gorelease-dry-run-docker
+.PHONY: test test-race test-coverage harness cli-wayfinding docs-wayfinding install-smoke provider-conformance-mock provider-conformance lint fmt install-tools proto clean help gorelease-dry-run gorelease-dry-run-docker
 
 # Default target
 help:
@@ -19,7 +19,6 @@ help:
 	@echo "  make test-coverage - Run tests with coverage"
 	@echo "  make lint          - Run linter"
 	@echo "  make harness       - Run deterministic getting-started and end-to-end harnesses"
-	@echo "  make inner-loop    - Verify scaffold → run/chat/inspect → deploy dry-run contract"
 	@echo "  make cli-wayfinding - Verify installed first-agent CLI wayfinding commands"
 	@echo "  make docs-wayfinding - Verify first-agent docs wayfinding links resolve locally"
 	@echo "  make install-smoke - Verify the local install.sh and first-run CLI smoke path"
@@ -53,26 +52,16 @@ test-coverage:
 # run/chat/inspect, and 0→hero regressions before a PR is opened.
 harness:
 	$(MAKE) cli-wayfinding
-	$(MAKE) inner-loop
+	go test ./cmd/micro/cli/new -run TestZeroToOne -count=1
 	./internal/harness/zero-to-hero-ci/run.sh
 	go run ./internal/harness/agent-flow
 	$(MAKE) provider-conformance-mock
 
-# Focused provider-free CLI inner-loop contract: scaffold a service, keep the
-# run/chat/inspect commands discoverable, and prove deploy dry-run reaches the
-# documented boundary without remote side effects. Use this when README/docs/CLI
-# drift is the concern and the full runtime harness is more than you need.
-inner-loop:
-	go test ./cmd/micro/cli/new -run TestZeroToOne -count=1
-	go test ./cmd/micro -run 'TestFirstAgentWalkthroughCLIBoundaries|TestZeroToHeroCLIBoundaries|TestZeroToHeroCommandPrintsMaintainedNoSecretPath' -count=1
-	go test ./cmd/micro/cli/deploy -run TestDeployDryRun -count=1
-	go test ./internal/harness/zero-to-hero-ci -run 'TestZeroToHeroDeployDryRunCommandSmoke|TestNoSecretFirstAgentDebuggingSmoke|TestYourFirstAgentTutorialSmoke' -count=1
-
 # Verify the installed CLI keeps the first-agent on-ramp commands discoverable.
 # This guards the no-secret commands README/docs recommend (`micro agent demo`,
 # `micro examples`, and `micro zero-to-hero`) as a CI contract.
 cli-wayfinding:
-	go test ./cmd/micro -run 'TestFirstAgentWalkthroughCLIBoundaries|TestExamplesWayfindingIndexStaysLinked|TestExamplesCommandPointsAtWayfindingIndex|TestZeroToHeroCommandPrintsMaintainedNoSecretPath' -count=1
+	go test ./cmd/micro -run 'TestFirstAgentWalkthroughCLIBoundaries|TestExamplesWayfinding' -count=1
 	$(MAKE) docs-wayfinding
 	$(MAKE) install-smoke
 

README.md

@@ -78,12 +78,6 @@ access or provider keys, use:
 make install-smoke
 ```
 
-To verify the focused CLI inner-loop contract — scaffold → run/chat/inspect → deploy dry-run — use:
-
-```bash
-make inner-loop
-```
-
 To run the broader local contract (including the [0→hero services → agents → workflows path](internal/website/docs/guides/zero-to-hero.md),
 chat/inspect CLI boundaries, and deploy dry-run), use:
 

ROADMAP.md

@@ -14,9 +14,8 @@ The full, current roadmap lives at **[go-micro.dev/docs/roadmap](https://go-micr
 
 ## Where we are (v6)
 
-Services, agents (`plan`/`delegate`, guardrails, memory, tool middleware,
-checkpoint/resume, and OpenTelemetry run spans), durable flows, the MCP and A2A
-gateways (both directions, including A2A streaming,
+Services, agents (`plan`/`delegate`, guardrails, memory, tool middleware), durable
+flows, the MCP and A2A gateways (both directions, including A2A streaming,
 push notifications, and multi-turn continuation), x402 paid tools, secure by
 default.
 
@@ -40,24 +39,11 @@ default.
   propagation, retry/backoff.
 - **Getting-started contract** — define and CI-verify the 0→1 and 0→hero flows.
 
-## Shipped agent depth
-
-- **Durable agent loop** — opt-in `Checkpoint` support lets agent `Ask` and
-  streaming runs persist, list pending work, and resume without replaying completed
-  tool calls. Human-input pauses resume through explicit input helpers.
-- **Agent observability** — agent `RunInfo` now feeds OpenTelemetry spans/events
-  across runs, model turns, tool calls, retries, delegation lineage, and resume
-  checkpoints.
-
 ## Next — agentic depth
 
+- **Durable agent loop** — resume a long run via `Checkpoint` (flows already do).
 - **Streaming** — broaden provider-backed `ai.Stream` coverage and keep chat/A2A streaming end to end.
-- **Resume operations polish** — keep improving CLI/docs breadcrumbs for finding
-  pending agent runs and deciding whether to call resume, resume-input, or stream
-  resume in production.
-- **Observability hardening** — keep span attributes and run inspection coherent
-  across agents, flows, and gateways as more providers and workflow paths are
-  exercised.
+- **Agent observability** — `RunInfo` → OpenTelemetry spans.
 
 ## Later
 

agent/agent.go

@@ -33,7 +33,6 @@ import (
 	_ "go-micro.dev/v6/ai/atlascloud"
 	_ "go-micro.dev/v6/ai/gemini"
 	_ "go-micro.dev/v6/ai/groq"
-	_ "go-micro.dev/v6/ai/minimax"
 	_ "go-micro.dev/v6/ai/mistral"
 	_ "go-micro.dev/v6/ai/ollama"
 	_ "go-micro.dev/v6/ai/openai"
@@ -415,15 +414,6 @@ func (a *agentImpl) askLocked(ctx context.Context, runID, message, parentRunID s
 				continue
 			}
 		}
-		if toolName := partialTextToolCallName(resp.Reply, toolList); len(resp.ToolCalls) == 0 && toolName != "" && planCompletionTurn < maxPlanCompletionTurns {
-			if resp.Reply != "" {
-				a.mem.Add("assistant", resp.Reply)
-			}
-			message = fmt.Sprintf("Your previous response started a %q tool call but did not finish valid tool-call markup or JSON arguments, so no tool was executed. Retry the same step now by emitting one complete valid tool call for %q. Do not describe the action in prose, and do not claim completion until the tool call succeeds.", toolName, toolName)
-			a.mem.Add("user", message)
-			messages = a.mem.Messages()
-			continue
-		}
 		break
 	}
 
@@ -442,13 +432,9 @@ func (a *agentImpl) askLocked(ctx context.Context, runID, message, parentRunID s
 		reply += resp.Answer
 	}
 
-	completedToolCalls := checkpointToolCalls(run.Steps)
-	if a.currentRun != nil {
-		completedToolCalls = checkpointToolCalls(a.currentRun.Steps)
-	}
 	res := &Response{
 		Reply:     reply,
-		ToolCalls: mergeCheckpointToolCalls(completedToolCalls, resp.ToolCalls),
+		ToolCalls: resp.ToolCalls,
 		Agent:     a.opts.Name,
 		RunID:     a.runID,
 		ParentID:  parentRunID,

agent/agent_test.go

@@ -38,16 +38,6 @@ func TestNew(t *testing.T) {
 	}
 }
 
-func TestBundledProviderImportsIncludeMiniMaxForConformance(t *testing.T) {
-	if model := ai.New("minimax", ai.WithAPIKey("test-key")); model == nil {
-		t.Fatal("ai.New(\"minimax\") returned nil; agent live conformance cannot exercise MiniMax")
-	}
-	caps := ai.ProviderCapabilities("minimax")
-	if !caps.Stream || !caps.ToolStream {
-		t.Fatalf("MiniMax capabilities = %#v, want streaming and tool streaming registered", caps)
-	}
-}
-
 func TestChatResponseIncludesRunIDs(t *testing.T) {
 	fakeGen = func(ctx context.Context, opts ai.Options, req *ai.Request) (*ai.Response, error) {
 		return &ai.Response{Reply: "ok"}, nil

agent/checkpoint.go

@@ -4,7 +4,6 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
-	"strings"
 	"time"
 
 	"go-micro.dev/v6/ai"
@@ -289,56 +288,3 @@ func upsertStep(steps *[]flow.StepRecord, rec flow.StepRecord) int {
 	*steps = append(*steps, rec)
 	return len(*steps) - 1
 }
-
-func checkpointToolCalls(steps []flow.StepRecord) []ai.ToolCall {
-	calls := make([]ai.ToolCall, 0, len(steps))
-	for _, step := range steps {
-		call, ok := checkpointToolCall(step)
-		if !ok {
-			continue
-		}
-		calls = append(calls, call)
-	}
-	return calls
-}
-
-func checkpointToolCall(step flow.StepRecord) (ai.ToolCall, bool) {
-	if step.Status != "done" || !strings.HasPrefix(step.Name, "tool:") {
-		return ai.ToolCall{}, false
-	}
-	parts := strings.SplitN(strings.TrimPrefix(step.Name, "tool:"), ":", 2)
-	if len(parts) != 2 || parts[0] == "" {
-		return ai.ToolCall{}, false
-	}
-	input := map[string]any{}
-	if parts[1] != "null" && parts[1] != "" {
-		if err := json.Unmarshal([]byte(parts[1]), &input); err != nil {
-			return ai.ToolCall{}, false
-		}
-	}
-	return ai.ToolCall{Name: parts[0], Input: input, Result: step.Result}, true
-}
-
-func mergeCheckpointToolCalls(checkpointed, current []ai.ToolCall) []ai.ToolCall {
-	if len(checkpointed) == 0 {
-		return current
-	}
-	seen := make(map[string]struct{}, len(current))
-	for _, call := range current {
-		seen[toolCallKey(call.Name, call.Input)] = struct{}{}
-	}
-	merged := make([]ai.ToolCall, 0, len(checkpointed)+len(current))
-	for _, call := range checkpointed {
-		if _, ok := seen[toolCallKey(call.Name, call.Input)]; ok {
-			continue
-		}
-		merged = append(merged, call)
-	}
-	merged = append(merged, current...)
-	return merged
-}
-
-func toolCallKey(name string, input map[string]any) string {
-	b, _ := json.Marshal(input)
-	return name + ":" + string(b)
-}

agent/checkpoint_test.go

@@ -21,7 +21,7 @@ func TestResumeCompletedCheckpointDoesNotReplayModel(t *testing.T) {
 	calls := 0
 	fakeGen = func(ctx context.Context, opts ai.Options, req *ai.Request) (*ai.Response, error) {
 		calls++
-		return &ai.Response{Reply: "done", ToolCalls: []ai.ToolCall{{ID: "call-1", Name: "external.lookup", Result: "cached"}}}, nil
+		return &ai.Response{Reply: "done"}, nil
 	}
 	defer func() { fakeGen = nil }()
 
@@ -49,9 +49,6 @@ func TestResumeCompletedCheckpointDoesNotReplayModel(t *testing.T) {
 	if resumed.RunID != resp.RunID {
 		t.Fatalf("resumed run id = %q, want %q", resumed.RunID, resp.RunID)
 	}
-	if len(resumed.ToolCalls) != 1 || resumed.ToolCalls[0].Name != "external.lookup" || resumed.ToolCalls[0].Result != "cached" {
-		t.Fatalf("resumed tool calls = %#v, want persisted completed call", resumed.ToolCalls)
-	}
 	if calls != 1 {
 		t.Fatalf("model calls after Resume = %d, want 1", calls)
 	}
@@ -104,12 +101,6 @@ func TestResumeFailedCheckpointDoesNotReplayCompletedTool(t *testing.T) {
 	if resp.Reply != "finished from checkpoint" {
 		t.Fatalf("Resume reply = %q", resp.Reply)
 	}
-	if len(resp.ToolCalls) != 1 || resp.ToolCalls[0].Name != "external.charge" || resp.ToolCalls[0].Result != "charged" {
-		t.Fatalf("resumed tool calls = %#v, want preserved completed charge call", resp.ToolCalls)
-	}
-	if got := resp.ToolCalls[0].Input["order"]; got != "42" {
-		t.Fatalf("resumed tool input order = %#v, want 42", got)
-	}
 	if toolRuns != 1 {
 		t.Fatalf("tool executions after Resume = %d, want completed tool was not replayed", toolRuns)
 	}
@@ -406,71 +397,6 @@ func TestResumeFailedCheckpointAfterFreshAgentRestart(t *testing.T) {
 	}
 }
 
-func TestResumePendingAfterFreshAgentRestartDoesNotReplayCompletedTool(t *testing.T) {
-	ctx := context.Background()
-	st := store.NewMemoryStore()
-	cp := flow.StoreCheckpoint(st, "startup-resume-agent")
-	toolRuns := 0
-	failFirst := true
-	fakeGen = func(ctx context.Context, opts ai.Options, req *ai.Request) (*ai.Response, error) {
-		if opts.ToolHandler != nil {
-			res := opts.ToolHandler(ctx, ai.ToolCall{ID: "call-1", Name: "external.allocate", Input: map[string]any{"cluster": "blue"}})
-			if res.Content != "allocated" {
-				t.Fatalf("tool result = %q, want allocated", res.Content)
-			}
-		}
-		if failFirst {
-			failFirst = false
-			return nil, errors.New("process stopped before final response")
-		}
-		return &ai.Response{Reply: "startup recovery complete"}, nil
-	}
-	defer func() { fakeGen = nil }()
-
-	newAgent := func() *agentImpl {
-		return newTestAgent(Name("startup-resume-agent"), WithStore(st), WithCheckpoint(cp),
-			WithTool("external.allocate", "allocate capacity once", nil, func(context.Context, map[string]any) (string, error) {
-				toolRuns++
-				return "allocated", nil
-			}))
-	}
-
-	first := newAgent()
-	_, err := first.Ask(ctx, "allocate blue capacity")
-	if err == nil {
-		t.Fatal("Ask succeeded, want simulated process stop")
-	}
-	if toolRuns != 1 {
-		t.Fatalf("tool executions after failed Ask = %d, want 1", toolRuns)
-	}
-
-	restarted := newAgent()
-	failedRun, err := ResumePending(ctx, restarted)
-	if err != nil {
-		t.Fatalf("ResumePending after restart: failedRun=%q err=%v", failedRun, err)
-	}
-	if failedRun != "" {
-		t.Fatalf("failed run = %q, want none", failedRun)
-	}
-	if toolRuns != 1 {
-		t.Fatalf("tool executions after ResumePending = %d, want completed tool not replayed", toolRuns)
-	}
-	runs, err := Pending(ctx, restarted)
-	if err != nil {
-		t.Fatalf("Pending after ResumePending: %v", err)
-	}
-	if len(runs) != 0 {
-		t.Fatalf("Pending after ResumePending = %#v, want none", runs)
-	}
-	summaries, err := ListRunSummaries(st, "startup-resume-agent")
-	if err != nil {
-		t.Fatalf("ListRunSummaries after ResumePending: %v", err)
-	}
-	if len(summaries) != 1 || summaries[0].Status != "done" || summaries[0].Checkpoint != "done" {
-		t.Fatalf("summary after ResumePending = %#v, want one done run", summaries)
-	}
-}
-
 func TestResumeFailedCheckpointDoesNotDuplicateCompactedMemory(t *testing.T) {
 	ctx := context.Background()
 	st := store.NewMemoryStore()

agent/conformance_test.go

@@ -4,7 +4,6 @@ import (
 	"context"
 	"errors"
 	"fmt"
-	"io"
 	"os"
 	"strings"
 	"testing"
@@ -46,120 +45,6 @@ func TestAgentProviderConformanceMatrix(t *testing.T) {
 	}
 }
 
-func TestAgentProviderStreamConformanceMatrix(t *testing.T) {
-	providers := []conformanceProvider{
-		{name: "fake"},
-		{name: "openai", key: "OPENAI_API_KEY", model: "GO_MICRO_CONFORMANCE_OPENAI_MODEL", live: true},
-		{name: "anthropic", key: "ANTHROPIC_API_KEY", model: "GO_MICRO_CONFORMANCE_ANTHROPIC_MODEL", live: true},
-		{name: "atlascloud", key: "ATLASCLOUD_API_KEY", model: "GO_MICRO_CONFORMANCE_ATLASCLOUD_MODEL", live: true},
-		{name: "groq", key: "GROQ_API_KEY", model: "GO_MICRO_CONFORMANCE_GROQ_MODEL", live: true},
-		{name: "minimax", key: "MINIMAX_API_KEY", model: "GO_MICRO_CONFORMANCE_MINIMAX_MODEL", live: true},
-		{name: "mistral", key: "MISTRAL_API_KEY", model: "GO_MICRO_CONFORMANCE_MISTRAL_MODEL", live: true},
-		{name: "together", key: "TOGETHER_API_KEY", model: "GO_MICRO_CONFORMANCE_TOGETHER_MODEL", live: true},
-	}
-
-	selected := selectedConformanceProviders(os.Getenv("GO_MICRO_AGENT_CONFORMANCE_PROVIDERS"))
-	for _, provider := range providers {
-		provider := provider
-		if len(selected) > 0 && !selected[provider.name] {
-			continue
-		}
-		t.Run(provider.name, func(t *testing.T) {
-			runAgentStreamConformanceScenario(t, provider)
-		})
-	}
-}
-
-func runAgentStreamConformanceScenario(t *testing.T, provider conformanceProvider) {
-	t.Helper()
-	if provider.live {
-		if os.Getenv(provider.key) == "" {
-			t.Skipf("%s not set; skipping live %s stream conformance", provider.key, provider.name)
-		}
-		if os.Getenv("GO_MICRO_AGENT_CONFORMANCE_LIVE") == "" {
-			t.Skipf("GO_MICRO_AGENT_CONFORMANCE_LIVE not set; skipping live %s stream conformance", provider.name)
-		}
-		caps := ai.ProviderCapabilities(provider.name)
-		if !caps.Stream {
-			t.Fatalf("ProviderCapabilities(%q).Stream = false, want true for stream conformance", provider.name)
-		}
-		if !caps.ToolStream {
-			t.Skipf("ProviderCapabilities(%q).ToolStream = false; skipping live tool stream conformance", provider.name)
-		}
-	} else {
-		var sawToolSchema bool
-		fakeStream = func(ctx context.Context, opts ai.Options, req *ai.Request) (ai.Stream, error) {
-			if req.Prompt != "Stream exactly: agent-stream-conformance-ok" {
-				return nil, fmt.Errorf("prompt = %q", req.Prompt)
-			}
-			if len(req.Messages) == 0 || req.Messages[len(req.Messages)-1].Role != "user" || req.Messages[len(req.Messages)-1].Content != req.Prompt {
-				return nil, fmt.Errorf("messages = %#v, want current user turn", req.Messages)
-			}
-			for _, tool := range req.Tools {
-				if tool.Name == "conformance_echo" {
-					sawToolSchema = true
-				}
-			}
-			if !sawToolSchema {
-				return nil, errors.New("stream request omitted conformance tool schema")
-			}
-			return &sliceStream{chunks: []string{"agent-stream-", "conformance-ok"}}, nil
-		}
-		defer func() { fakeStream = nil }()
-	}
-
-	agentOpts := []Option{
-		Name("stream-conformance-" + provider.name),
-		Provider(provider.name),
-		APIKey(os.Getenv(provider.key)),
-		Prompt("Stream conformance: preserve the exact requested marker in the final answer."),
-		WithRegistry(registry.NewMemoryRegistry()),
-		WithStore(store.NewMemoryStore()),
-		WithMemory(NewInMemory(8)),
-		ModelCallTimeout(45 * time.Second),
-		WithTool("conformance_echo", "Echo a conformance value and return a deterministic marker.", map[string]any{
-			"value": map[string]any{"type": "string", "description": "value to echo"},
-		}, func(ctx context.Context, input map[string]any) (string, error) {
-			return `{"marker":"agent-stream-conformance-ok"}`, nil
-		}),
-	}
-	if provider.model != "" {
-		if model := os.Getenv(provider.model); model != "" {
-			agentOpts = append(agentOpts, Model(model))
-		}
-	}
-
-	stream, err := New(agentOpts...).Stream(context.Background(), "Stream exactly: agent-stream-conformance-ok")
-	if err != nil {
-		t.Fatalf("Stream: %v", err)
-	}
-	defer stream.Close()
-
-	var reply strings.Builder
-	deadline := time.After(45 * time.Second)
-	for {
-		select {
-		case <-deadline:
-			t.Fatal("timed out waiting for streamed final output")
-		default:
-		}
-		chunk, err := stream.Recv()
-		if errors.Is(err, io.EOF) {
-			break
-		}
-		if err != nil {
-			t.Fatalf("Recv: %v", err)
-		}
-		reply.WriteString(chunk.Reply)
-		if strings.Contains(reply.String(), "agent-stream-conformance-ok") {
-			return
-		}
-	}
-	if got := reply.String(); !strings.Contains(got, "agent-stream-conformance-ok") {
-		t.Fatalf("streamed reply %q does not include conformance marker", got)
-	}
-}
-
 func selectedConformanceProviders(csv string) map[string]bool {
 	out := map[string]bool{}
 	for _, part := range strings.Split(csv, ",") {
@@ -402,20 +287,6 @@ func TestAgentProviderConformanceFinalDelegateRetryUsesTaggedCall(t *testing.T)
 	}
 }
 
-func TestAgentProviderConformanceMarkerRetryRequiresExactMarkerReply(t *testing.T) {
-	prompt := nextConformanceRetryPrompt(true, true, false, 2)
-	for _, want := range []string{
-		"omitted the conformance marker",
-		"do not call more tools",
-		"do not summarize",
-		"Reply with exactly this sentence: agent-conformance-ok after guarded delegate refusal.",
-	} {
-		if !strings.Contains(prompt, want) {
-			t.Fatalf("marker retry prompt %q missing %q", prompt, want)
-		}
-	}
-}
-
 func nextConformanceRetryPrompt(sawTool, sawBlockedDelegate, hasMarker bool, attempt int) string {
 	if attempt >= 4 && sawTool && !sawBlockedDelegate {
 		return "Final conformance retry: emit exactly this tagged tool call so the harness can execute the guarded delegate refusal, then include agent-conformance-ok and the refusal in the final answer: " + conformanceDelegateTaggedCall
@@ -426,7 +297,7 @@ func nextConformanceRetryPrompt(sawTool, sawBlockedDelegate, hasMarker bool, att
 	case !sawBlockedDelegate:
 		return "The previous response called conformance_echo but did not attempt the required guarded delegation. Continue the same conformance check now: call delegate exactly once with input " + conformanceDelegateInputJSON + "; do not answer in prose until that delegate call has been attempted. If native tool_calls are unavailable, emit exactly " + conformanceDelegateTaggedCall + ". The delegate is expected to be refused by policy; include that refusal and the agent-conformance marker in the final answer."
 	case !hasMarker:
-		return "The previous response completed the required tool calls but omitted the conformance marker. Continue the same conformance check now: do not call more tools, do not summarize, and do not use synonyms. Reply with exactly this sentence: agent-conformance-ok after guarded delegate refusal."
+		return "The previous response completed the required tool calls but omitted the conformance marker. Continue the same conformance check now: do not call more tools; answer with the prior echo result marker agent-conformance-ok and mention the guarded delegate refusal."
 	default:
 		return "Retry the provider conformance check and include the agent-conformance marker in the final answer."
 	}
@@ -746,61 +617,6 @@ func TestAgentExecutesProviderTextToolCallFallback(t *testing.T) {
 	}
 }
 
-func TestAgentRepairsPartialTextToolCallFallback(t *testing.T) {
-	attempts := 0
-	fakeGen = func(ctx context.Context, opts ai.Options, req *ai.Request) (*ai.Response, error) {
-		if opts.ToolHandler == nil {
-			return nil, errors.New("missing tool handler")
-		}
-		attempts++
-		if attempts == 1 {
-			return &ai.Response{Reply: `<tool_call name="conformance_echo">`}, nil
-		}
-		if !strings.Contains(req.Prompt, "did not finish valid tool-call markup") {
-			return nil, fmt.Errorf("repair prompt = %q, want partial tool-call repair guidance", req.Prompt)
-		}
-		return &ai.Response{
-			Reply: `<tool_call name="conformance_echo">{"value":"agent-conformance"}</tool_call>`,
-		}, nil
-	}
-	defer func() { fakeGen = nil }()
-
-	var sawTool bool
-	a := New(
-		Name("conformance-partial-text-tool"),
-		Provider("fake"),
-		WithRegistry(registry.NewMemoryRegistry()),
-		WithStore(store.NewMemoryStore()),
-		WithMemory(NewInMemory(4)),
-		WithTool("conformance_echo", "Echo a conformance value.", map[string]any{
-			"value": map[string]any{"type": "string"},
-		}, func(ctx context.Context, input map[string]any) (string, error) {
-			sawTool = true
-			if input["value"] != "agent-conformance" {
-				return "", fmt.Errorf("unexpected value %v", input["value"])
-			}
-			return `{"marker":"agent-conformance-ok"}`, nil
-		}),
-	)
-
-	resp, err := a.Ask(context.Background(), "Run the partial text tool call fallback.")
-	if err != nil {
-		t.Fatalf("Ask: %v", err)
-	}
-	if attempts != 2 {
-		t.Fatalf("attempts = %d, want repair retry", attempts)
-	}
-	if !sawTool {
-		t.Fatal("repaired text tool call fallback did not execute the tool")
-	}
-	if len(resp.ToolCalls) != 1 || resp.ToolCalls[0].Name != "conformance_echo" {
-		t.Fatalf("ToolCalls = %+v, want conformance_echo", resp.ToolCalls)
-	}
-	if !strings.Contains(resp.Reply, "agent-conformance-ok") {
-		t.Fatalf("Reply = %q, want tool result marker", resp.Reply)
-	}
-}
-
 func TestAgentExecutesTextToolCallFallbackAfterStructuredToolCall(t *testing.T) {
 	fakeGen = func(ctx context.Context, opts ai.Options, req *ai.Request) (*ai.Response, error) {
 		if opts.ToolHandler == nil {

agent/integration_test.go

@@ -68,8 +68,6 @@ func init() {
 		_ = m.Init(opts...)
 		return m
 	})
-	ai.RegisterStream("fake")
-	ai.RegisterToolStream("fake")
 }
 
 // fakeClient embeds the default client (so NewRequest works) and

agent/otel.go

@@ -374,14 +374,13 @@ func (a *agentImpl) traceTool(next ai.ToolHandler) ai.ToolHandler {
 			return res
 		}
 
-		spanAttrs := appendRunInfoAttributes([]attribute.KeyValue{
+		ctx, span := a.tracer().Start(ctx, spanNameToolCall, trace.WithAttributes(
 			attribute.String(AttrRunID, info.RunID),
 			attribute.String(AttrParentRunID, info.ParentID),
 			attribute.String(AttrAgentName, info.Agent),
 			attribute.String(AttrToolName, call.Name),
 			attribute.Bool(AttrDelegate, call.Name == toolDelegate),
-		}, info)
-		ctx, span := a.tracer().Start(ctx, spanNameToolCall, trace.WithAttributes(spanAttrs...))
+		))
 		res := next(ctx, call)
 		dur := time.Since(start).Milliseconds()
 		attrs := []attribute.KeyValue{attribute.Int64(AttrLatencyMS, dur)}

agent/otel_test.go

@@ -103,10 +103,8 @@ func TestAgentOpenTelemetrySpans(t *testing.T) {
 				t.Fatalf("model span missing model event: %#v", s.Events())
 			}
 		}
-		if s.Name() == spanNameToolCall {
-			if !spanEventHasRunInfo(s.Events(), "agent.tool", runID, "runner") {
-				t.Fatalf("tool span missing tool event: %#v", s.Events())
-			}
+		if s.Name() == spanNameToolCall && !spanEventHasRunInfo(s.Events(), "agent.tool", runID, "runner") {
+			t.Fatalf("tool span missing tool event: %#v", s.Events())
 		}
 	}
 	keys, err := store.Scope(st, "agent", "runner").List(store.ListPrefix("runs/"))
@@ -144,45 +142,6 @@ func TestAgentOpenTelemetrySpans(t *testing.T) {
 	}
 }
 
-func TestAgentOpenTelemetryToolSpanIncludesWorkflowRunInfo(t *testing.T) {
-	exp := tracetest.NewInMemoryExporter()
-	tp := trace.NewTracerProvider(trace.WithSyncer(exp))
-	st := store.NewMemoryStore()
-	a := New(Name("workflow-tool"), Provider("oteltest"), WithStore(st), TraceProvider(tp)).(*agentImpl)
-	handler := a.traceTool(func(context.Context, ai.ToolCall) ai.ToolResult {
-		return ai.ToolResult{Value: "ok"}
-	})
-	ctx := ai.WithRunInfo(context.Background(), ai.RunInfo{
-		RunID:    "run-workflow-tool",
-		ParentID: "parent-run",
-		Agent:    "workflow-tool",
-		Flow:     "deploy",
-		Step:     "notify",
-		Dispatch: "workflow",
-		Trigger:  "manual",
-	})
-
-	res := handler(ctx, ai.ToolCall{ID: "call-1", Name: "notify", Input: map[string]any{"ok": true}})
-	if resultError(res) != "" {
-		t.Fatalf("tool returned error: %#v", res)
-	}
-
-	for _, span := range exp.GetSpans().Snapshots() {
-		if span.Name() != spanNameToolCall {
-			continue
-		}
-		attrs := spanAttributes(span.Attributes())
-		if attrs[AttrRunID] != "run-workflow-tool" || attrs[AttrParentRunID] != "parent-run" || attrs[AttrAgentName] != "workflow-tool" {
-			t.Fatalf("tool span missing run lineage: %#v", attrs)
-		}
-		if attrs[AttrFlowName] != "deploy" || attrs[AttrFlowStep] != "notify" || attrs[AttrDispatch] != "workflow" || attrs[AttrTrigger] != "manual" {
-			t.Fatalf("tool span missing workflow run info: %#v", attrs)
-		}
-		return
-	}
-	t.Fatalf("tool span not emitted; got %d spans", len(exp.GetSpans().Snapshots()))
-}
-
 func TestAgentOpenTelemetryToolRetryAttempts(t *testing.T) {
 	exp := tracetest.NewInMemoryExporter()
 	tp := trace.NewTracerProvider(trace.WithSyncer(exp))

agent/resilience_test.go

@@ -240,55 +240,6 @@ func TestAskCancellationDuringToolCallFailsRun(t *testing.T) {
 	}
 }
 
-func TestSlowProviderTimeoutPreventsLateToolSideEffects(t *testing.T) {
-	started := make(chan struct{})
-	release := make(chan struct{})
-	done := make(chan struct{})
-	fakeGen = func(ctx context.Context, opts ai.Options, req *ai.Request) (*ai.Response, error) {
-		close(started)
-		<-release
-		defer close(done)
-		if opts.ToolHandler == nil {
-			t.Fatal("missing tool handler")
-		}
-		res := opts.ToolHandler(ctx, ai.ToolCall{ID: "late-1", Name: "external.create", Input: map[string]any{"title": "too late"}})
-		if !strings.Contains(res.Content, context.DeadlineExceeded.Error()) {
-			t.Errorf("late tool result = %q, want deadline exceeded", res.Content)
-		}
-		return &ai.Response{Reply: "late", ToolCalls: []ai.ToolCall{{ID: "late-1", Name: "external.create", Input: map[string]any{"title": "too late"}, Result: res.Content}}}, nil
-	}
-	defer func() { fakeGen = nil }()
-
-	toolRuns := 0
-	a := newTestAgent(
-		Name("slow-provider-late-tool"),
-		ModelCallTimeout(10*time.Millisecond),
-		WithTool("external.create", "create once", nil, func(context.Context, map[string]any) (string, error) {
-			toolRuns++
-			return "created", nil
-		}),
-	)
-
-	_, err := a.Ask(context.Background(), "provider times out before tool")
-	if !errors.Is(err, context.DeadlineExceeded) {
-		t.Fatalf("Ask error = %v, want deadline exceeded", err)
-	}
-	select {
-	case <-started:
-	default:
-		t.Fatal("provider was not called")
-	}
-	close(release)
-	select {
-	case <-done:
-	case <-time.After(time.Second):
-		t.Fatal("late provider call did not finish")
-	}
-	if toolRuns != 0 {
-		t.Fatalf("late tool executions = %d, want 0", toolRuns)
-	}
-}
-
 func TestAskCheckpointRecordsTerminalOperationalFailureStatus(t *testing.T) {
 	tests := []struct {
 		name string

agent/text_tool_calls.go

@@ -15,7 +15,6 @@ var fencedJSONBlock = regexp.MustCompile("(?s)```(?:json)?\\s*(.*?)\\s*```")
 var taggedToolCallBlock = regexp.MustCompile(`(?s)<[^<>]*(?:tool_call|tool_calls|function=)[^<>]*>(.*?)</[^<>]*>`)
 var singleTaggedToolCall = regexp.MustCompile(`(?s)<(tool_call\b[^<>]*|[^<>]*function\s*=[^<>]*)>(.*?)</[^<>]*>`)
 var taggedToolNameAttr = regexp.MustCompile(`(?i)(?:function|name|tool)\s*=\s*["\']?([^"\'\s>]+)`)
-var openingTaggedToolCall = regexp.MustCompile(`(?i)<(tool_call\b[^<>]*|[^<>]*function\s*=[^<>]*)>`)
 
 type textToolCall struct {
 	ID        string         `json:"id"`
@@ -114,37 +113,6 @@ func parseTextToolCalls(text string, tools []ai.Tool) []ai.ToolCall {
 	return nil
 }
 
-func partialTextToolCallName(text string, tools []ai.Tool) string {
-	text = html.UnescapeString(text)
-	allowed := textToolNames(tools)
-	if len(allowed) == 0 {
-		return ""
-	}
-	openMatches := openingTaggedToolCall.FindAllStringSubmatchIndex(text, -1)
-	if len(openMatches) == 0 {
-		return ""
-	}
-	closedMatches := singleTaggedToolCall.FindAllStringSubmatchIndex(text, -1)
-	for _, open := range openMatches {
-		closed := false
-		for _, match := range closedMatches {
-			if match[0] == open[0] {
-				closed = true
-				break
-			}
-		}
-		if closed {
-			continue
-		}
-		tag := text[open[2]:open[3]]
-		name := taggedToolName(tag)
-		if canonical := allowed[name]; canonical != "" {
-			return canonical
-		}
-	}
-	return ""
-}
-
 func textToolNames(tools []ai.Tool) map[string]string {
 	allowed := map[string]string{}
 	for _, tool := range tools {

ai/anthropic/anthropic.go

@@ -19,7 +19,6 @@ func init() {
 		return NewProvider(opts...)
 	})
 	ai.RegisterStream("anthropic")
-	ai.RegisterToolStream("anthropic")
 }
 
 // Provider implements the ai.Model interface for Anthropic Claude

ai/atlascloud/atlascloud.go

@@ -96,7 +96,6 @@ func (p *Provider) String() string      { return "atlascloud" }
 func (p *Provider) Generate(ctx context.Context, req *ai.Request, opts ...ai.GenerateOption) (*ai.Response, error) {
 	tools := atlascloudTools(req.Tools)
 	compatTools, compatPrompt := atlascloudMinimaxCompatTools(p.opts.Model, req.Tools)
-	textToolPrompt := atlascloudMinimaxTextToolPrompt(p.opts.Model, req.Tools)
 
 	messages := []map[string]any{
 		{"role": "system", "content": req.SystemPrompt},
@@ -129,43 +128,11 @@ func (p *Provider) Generate(ctx context.Context, req *ai.Request, opts ...ai.Gen
 			apiReq["tools"] = compatTools
 			resp, rawMessage, err = p.callAPI(ctx, "chat-minimax-compat", apiReq)
 		}
-		if atlascloudShouldRetryMinimaxTextTools(err, textToolPrompt) {
-			delete(apiReq, "tools")
-			apiReq["messages"] = append(messages, map[string]any{"role": "system", "content": textToolPrompt})
-			resp, rawMessage, err = p.callAPI(ctx, "chat-minimax-text-tools", apiReq)
-		}
 		if err != nil {
 			return nil, err
 		}
 	}
 
-	if toolName := atlascloudPartialTextToolCallName(resp.Reply, req.Tools); toolName != "" {
-		repairReq := map[string]any{
-			"model": p.opts.Model,
-			"messages": append(append([]map[string]any(nil), messages...),
-				map[string]any{"role": "assistant", "content": resp.Reply},
-				map[string]any{"role": "user", "content": fmt.Sprintf("Your previous response started a %q tool call but did not finish valid tool-call markup or JSON arguments, so no tool was executed. Retry the same step now by emitting one complete valid tool call for %q. Do not describe the action in prose, and do not claim completion until the tool call succeeds.", toolName, toolName)},
-			),
-		}
-		if p.opts.MaxTokens > 0 {
-			repairReq["max_tokens"] = p.opts.MaxTokens
-		}
-		if len(tools) > 0 {
-			repairReq["tools"] = tools
-		}
-		resp, rawMessage, err = p.callAPI(ctx, "chat-partial-tool-repair", repairReq)
-		if err != nil {
-			return nil, fmt.Errorf("atlascloud partial text tool-call repair failed for %q: %w", toolName, err)
-		}
-		if atlascloudPartialTextToolCallName(resp.Reply, req.Tools) != "" && len(resp.ToolCalls) == 0 {
-			if toolName == "plan" {
-				resp.Reply = atlascloudPlanFallbackTextToolCall(req.Prompt)
-			} else {
-				return nil, fmt.Errorf("atlascloud returned incomplete text tool call for %q after repair", toolName)
-			}
-		}
-	}
-
 	if len(resp.ToolCalls) == 0 {
 		return resp, nil
 	}
@@ -214,7 +181,6 @@ func (p *Provider) Generate(ctx context.Context, req *ai.Request, opts ...ai.Gen
 			if err != nil {
 				if atlascloudShouldRetryWithoutTools(err, followUpReq) {
 					delete(followUpReq, "tools")
-					followUpReq["messages"] = atlascloudFollowUpMessagesWithoutTools(p.opts.Model, followUpMessages)
 					followUpResp, followUpRawMessage, err = p.callAPI(ctx, "tool-follow-up-no-tools", followUpReq)
 				}
 				if err != nil {
@@ -460,89 +426,6 @@ func (p *Provider) callAPI(ctx context.Context, phase string, req map[string]any
 	return response, rawMessage, nil
 }
 
-func atlascloudFollowUpMessagesWithoutTools(model string, messages []map[string]any) []map[string]any {
-	if !atlascloudIsMinimaxModel(model) {
-		return messages
-	}
-	out := make([]map[string]any, 0, len(messages)+1)
-	for _, msg := range messages {
-		role, _ := msg["role"].(string)
-		switch role {
-		case "assistant":
-			converted := map[string]any{"role": "assistant"}
-			if content, _ := msg["content"].(string); content != "" {
-				converted["content"] = content
-			} else if calls, ok := msg["tool_calls"]; ok {
-				converted["content"] = "Tool call requested: " + atlascloudToolCallsText(calls)
-			} else {
-				converted["content"] = ""
-			}
-			out = append(out, converted)
-		case "tool":
-			toolID, _ := msg["tool_call_id"].(string)
-			content, _ := msg["content"].(string)
-			if toolID != "" {
-				content = "Tool result for " + toolID + ": " + content
-			} else {
-				content = "Tool result: " + content
-			}
-			out = append(out, map[string]any{"role": "user", "content": content})
-		default:
-			copyMsg := make(map[string]any, len(msg))
-			for k, v := range msg {
-				copyMsg[k] = v
-			}
-			out = append(out, copyMsg)
-		}
-	}
-	return out
-}
-
-func atlascloudToolCallsText(calls any) string {
-	b, err := json.Marshal(calls)
-	if err != nil {
-		return fmt.Sprint(calls)
-	}
-	return string(b)
-}
-
-func atlascloudPartialTextToolCallName(text string, tools []ai.Tool) string {
-	if !strings.Contains(text, "<tool_call") {
-		return ""
-	}
-	if strings.Contains(text, "</tool_call>") {
-		return ""
-	}
-	for _, tool := range tools {
-		for _, name := range []string{tool.Name, tool.OriginalName} {
-			if name == "" {
-				continue
-			}
-			if strings.Contains(text, `name="`+name+`"`) || strings.Contains(text, `name='`+name+`'`) {
-				return tool.Name
-			}
-		}
-	}
-	return ""
-}
-
-func atlascloudPlanFallbackTextToolCall(prompt string) string {
-	task := strings.TrimSpace(prompt)
-	if task == "" {
-		task = "continue the requested work"
-	}
-	args, err := json.Marshal(map[string]any{
-		"steps": []map[string]string{{
-			"task":   task,
-			"status": "pending",
-		}},
-	})
-	if err != nil {
-		return `<tool_call name="plan">{"steps":[{"task":"continue the requested work","status":"pending"}]}</tool_call>`
-	}
-	return `<tool_call name="plan">` + string(args) + `</tool_call>`
-}
-
 func atlascloudMinimaxCompatTools(model string, input []ai.Tool) ([]map[string]any, string) {
 	if !atlascloudIsMinimaxModel(model) || len(input) == 0 {
 		return nil, ""
@@ -566,32 +449,6 @@ func atlascloudMinimaxCompatTools(model string, input []ai.Tool) ([]map[string]a
 	return atlascloudTools(native), prompt
 }
 
-func atlascloudMinimaxTextToolPrompt(model string, input []ai.Tool) string {
-	if !atlascloudIsMinimaxModel(model) || len(input) == 0 {
-		return ""
-	}
-	names := make([]string, 0, len(input))
-	for _, tool := range input {
-		if tool.Name != "" {
-			names = append(names, tool.Name)
-		}
-	}
-	if len(names) == 0 {
-		return ""
-	}
-	return "AtlasCloud/minimax text-tool compatibility: the native tools payload was rejected. " +
-		"Call exactly one needed tool from this list by emitting exactly <tool_call name=\"tool_name\">{...}</tool_call>: " +
-		strings.Join(names, ", ") + ". Do not answer in prose instead of emitting the tag."
-}
-
-func atlascloudShouldRetryMinimaxTextTools(err error, prompt string) bool {
-	if prompt == "" {
-		return false
-	}
-	var apiErr *atlascloudAPIError
-	return errors.As(err, &apiErr) && apiErr.StatusCode() == http.StatusBadRequest
-}
-
 func atlascloudIsMinimaxModel(model string) bool {
 	model = strings.ToLower(model)
 	return strings.Contains(model, "minimax")

ai/atlascloud/atlascloud_test.go

@@ -520,105 +520,6 @@ func TestProvider_GeneratePreservesFollowUpTextToolCallInReply(t *testing.T) {
 	}
 }
 
-func TestProvider_GenerateRepairsInitialPartialTextToolCall(t *testing.T) {
-	var bodies []map[string]any
-	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
-		var body map[string]any
-		if err := json.NewDecoder(r.Body).Decode(&body); err != nil {
-			t.Fatalf("decode request: %v", err)
-		}
-		bodies = append(bodies, body)
-		w.Header().Set("Content-Type", "application/json")
-		switch len(bodies) {
-		case 1:
-			_, _ = w.Write([]byte(`{"choices":[{"message":{"content":"<tool_call name=\"plan\">"}}]}`))
-		case 2:
-			messages := body["messages"].([]any)
-			last := messages[len(messages)-1].(map[string]any)
-			if last["role"] != "user" || !strings.Contains(last["content"].(string), "did not finish valid tool-call markup") {
-				t.Fatalf("repair prompt = %#v, want partial tool-call guidance", last)
-			}
-			if _, ok := body["tools"]; !ok {
-				t.Fatalf("repair request did not keep tools available: %#v", body)
-			}
-			_, _ = w.Write([]byte(`{"choices":[{"message":{"content":"<tool_call name=\"plan\">{\"steps\":[{\"task\":\"create tasks\"}]}</tool_call>"}}]}`))
-		default:
-			t.Fatalf("unexpected API call %d", len(bodies))
-		}
-	}))
-	defer ts.Close()
-
-	p := NewProvider(
-		ai.WithAPIKey("test-key"),
-		ai.WithBaseURL(ts.URL),
-		ai.WithModel("minimaxai/minimax-m3"),
-	)
-	resp, err := p.Generate(context.Background(), &ai.Request{
-		Prompt: "plan and delegate",
-		Tools: []ai.Tool{
-			{Name: "plan", Description: "record a plan", Properties: map[string]any{"steps": map[string]any{"type": "array"}}},
-			{Name: "delegate", Description: "delegate work", Properties: map[string]any{"task": map[string]any{"type": "string"}}},
-		},
-	})
-	if err != nil {
-		t.Fatalf("Generate returned error: %v", err)
-	}
-	if !strings.Contains(resp.Reply, `<tool_call name="plan">`) || !strings.Contains(resp.Reply, `</tool_call>`) {
-		t.Fatalf("Reply = %q, want completed text tool call", resp.Reply)
-	}
-	if len(bodies) != 2 {
-		t.Fatalf("requests = %d, want initial plus repair", len(bodies))
-	}
-}
-
-func TestProvider_GenerateFallsBackAfterRepeatedPartialPlanTextToolCall(t *testing.T) {
-	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-		_, _ = w.Write([]byte(`{"choices":[{"message":{"content":"<tool_call name=\"plan\">"}}]}`))
-	}))
-	defer ts.Close()
-
-	p := NewProvider(
-		ai.WithAPIKey("test-key"),
-		ai.WithBaseURL(ts.URL),
-		ai.WithModel("minimaxai/minimax-m3"),
-	)
-	resp, err := p.Generate(context.Background(), &ai.Request{
-		Prompt: "plan and delegate",
-		Tools:  []ai.Tool{{Name: "plan", Description: "record a plan"}},
-	})
-	if err != nil {
-		t.Fatalf("Generate returned error: %v", err)
-	}
-	if !strings.Contains(resp.Reply, `<tool_call name="plan">`) || !strings.Contains(resp.Reply, `</tool_call>`) {
-		t.Fatalf("Reply = %q, want completed fallback plan text tool call", resp.Reply)
-	}
-	if !strings.Contains(resp.Reply, "plan and delegate") {
-		t.Fatalf("Reply = %q, want fallback plan seeded from prompt", resp.Reply)
-	}
-}
-
-func TestProvider_GenerateErrorsAfterRepeatedPartialNonPlanTextToolCall(t *testing.T) {
-	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-		_, _ = w.Write([]byte(`{"choices":[{"message":{"content":"<tool_call name=\"delegate\">"}}]}`))
-	}))
-	defer ts.Close()
-
-	p := NewProvider(
-		ai.WithAPIKey("test-key"),
-		ai.WithBaseURL(ts.URL),
-		ai.WithModel("minimaxai/minimax-m3"),
-	)
-	_, err := p.Generate(context.Background(), &ai.Request{
-		Prompt: "plan and delegate",
-		Tools:  []ai.Tool{{Name: "delegate", Description: "delegate work"}},
-	})
-	if err == nil || !strings.Contains(err.Error(), "incomplete text tool call") {
-		t.Fatalf("Generate error = %v, want incomplete text tool call error", err)
-	}
-}
-
 func TestProvider_GenerateRetriesMinimaxBuiltInsAsTextTools(t *testing.T) {
 	var bodies []map[string]any
 	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
@@ -677,60 +578,6 @@ func TestProvider_GenerateRetriesMinimaxBuiltInsAsTextTools(t *testing.T) {
 	}
 }
 
-func TestProvider_GenerateRetriesMinimaxServiceToolsAsTextTools(t *testing.T) {
-	var bodies []map[string]any
-	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
-		var body map[string]any
-		if err := json.NewDecoder(r.Body).Decode(&body); err != nil {
-			t.Fatalf("decode request: %v", err)
-		}
-		bodies = append(bodies, body)
-		w.Header().Set("Content-Type", "application/json")
-		switch len(bodies) {
-		case 1:
-			http.Error(w, `{"code":400,"msg":"bad request"}`, http.StatusBadRequest)
-		case 2:
-			if _, ok := body["tools"]; ok {
-				t.Fatalf("text-tool retry included native tools: %#v", body["tools"])
-			}
-			_, _ = w.Write([]byte(`{"choices":[{"message":{"content":"<tool_call name=\"conformance_echo\">{\"value\":\"agent-conformance\"}</tool_call>"}}]}`))
-		default:
-			t.Fatalf("unexpected API call %d", len(bodies))
-		}
-	}))
-	defer ts.Close()
-
-	p := NewProvider(ai.WithAPIKey("test-key"), ai.WithBaseURL(ts.URL), ai.WithModel("minimaxai/minimax-m3"))
-	resp, err := p.Generate(context.Background(), &ai.Request{
-		Prompt: "call a tool",
-		Tools: []ai.Tool{{
-			Name:        "conformance_echo",
-			Description: "echo conformance marker",
-			Properties:  map[string]any{"value": map[string]any{"type": "string"}},
-		}},
-	})
-	if err != nil {
-		t.Fatalf("Generate returned error: %v", err)
-	}
-	if !strings.Contains(resp.Reply, `<tool_call name="conformance_echo">`) {
-		t.Fatalf("Reply = %q, want text service-tool fallback", resp.Reply)
-	}
-	if len(bodies) != 2 {
-		t.Fatalf("requests = %d, want initial plus text-tool retry", len(bodies))
-	}
-	if _, ok := bodies[0]["tools"].([]any); !ok {
-		t.Fatalf("initial request did not include native tools: %#v", bodies[0])
-	}
-	msgs := bodies[1]["messages"].([]any)
-	compat := msgs[len(msgs)-1].(map[string]any)
-	content := compat["content"].(string)
-	for _, want := range []string{"native tools payload was rejected", `<tool_call name="tool_name">`, "conformance_echo"} {
-		if !strings.Contains(content, want) {
-			t.Fatalf("text-tool instruction %q missing %q", content, want)
-		}
-	}
-}
-
 func TestProvider_GenerateFollowUpRetriesWithoutToolsOnBadRequest(t *testing.T) {
 	var bodies []map[string]any
 	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
@@ -749,19 +596,6 @@ func TestProvider_GenerateFollowUpRetriesWithoutToolsOnBadRequest(t *testing.T)
 			if _, ok := body["tools"]; ok {
 				t.Fatalf("no-tools retry still included tools: %#v", body["tools"])
 			}
-			messages := body["messages"].([]any)
-			last := messages[len(messages)-1].(map[string]any)
-			if last["role"] == "tool" {
-				http.Error(w, `{"code":400,"msg":"trailing tool message rejected"}`, http.StatusBadRequest)
-				return
-			}
-			if last["role"] != "user" || !strings.Contains(last["content"].(string), "Tool result for call-1") {
-				t.Fatalf("no-tools retry last message = %#v, want user-visible tool result", last)
-			}
-			assistant := messages[len(messages)-2].(map[string]any)
-			if _, ok := assistant["tool_calls"]; ok {
-				t.Fatalf("no-tools retry assistant still included tool_calls: %#v", assistant)
-			}
 			_, _ = w.Write([]byte(`{"choices":[{"message":{"content":"done"}}]}`))
 		default:
 			t.Fatalf("unexpected API call %d", len(bodies))
@@ -809,7 +643,7 @@ func TestProvider_GenerateToolCallHTTPErrorIncludesRequestContext(t *testing.T)
 	p := NewProvider(
 		ai.WithAPIKey("test-key"),
 		ai.WithBaseURL(ts.URL),
-		ai.WithModel("deepseek-ai/DeepSeek-V3-0324"),
+		ai.WithModel("minimaxai/minimax-m3"),
 	)
 	_, err := p.Generate(context.Background(), &ai.Request{
 		Prompt: "call a tool",
@@ -823,7 +657,7 @@ func TestProvider_GenerateToolCallHTTPErrorIncludesRequestContext(t *testing.T)
 		t.Fatal("Generate error = nil, want 400")
 	}
 	msg := err.Error()
-	for _, want := range []string{"400 Bad Request", "atlascloud chat request", "model=deepseek-ai/DeepSeek-V3-0324", "tools=1", "tool_names=conformance_echo"} {
+	for _, want := range []string{"400 Bad Request", "atlascloud chat request", "model=minimaxai/minimax-m3", "tools=1", "tool_names=conformance_echo"} {
 		if !strings.Contains(msg, want) {
 			t.Fatalf("error %q missing %q", msg, want)
 		}

ai/capabilities.go

@@ -23,10 +23,6 @@ type Capabilities struct {
 	// Providers that only satisfy the Model interface with ErrStreamingUnsupported
 	// leave this false until their Stream implementation is usable.
 	Stream bool `json:"stream"`
-	// ToolStream reports whether the provider supports agent Stream requests that
-	// include tool schemas. Providers may support plain token streaming while
-	// leaving this false when their streaming API cannot accept tools.
-	ToolStream bool `json:"tool_stream"`
 }
 
 // ProviderCapabilities reports the capabilities registered for provider.
@@ -35,14 +31,12 @@ func ProviderCapabilities(provider string) Capabilities {
 	_, hasImage := imageProviders[provider]
 	_, hasVideo := videoProviders[provider]
 	_, hasStream := streamProviders[provider]
-	_, hasToolStream := toolStreamProviders[provider]
 
 	return Capabilities{
-		Model:      hasModel,
-		Image:      hasImage,
-		Video:      hasVideo,
-		Stream:     hasStream,
-		ToolStream: hasToolStream,
+		Model:  hasModel,
+		Image:  hasImage,
+		Video:  hasVideo,
+		Stream: hasStream,
 	}
 }
 
@@ -64,9 +58,6 @@ func CapabilityMatrix() map[string]Capabilities {
 	for name := range streamProviders {
 		names[name] = struct{}{}
 	}
-	for name := range toolStreamProviders {
-		names[name] = struct{}{}
-	}
 
 	matrix := make(map[string]Capabilities, len(names))
 	for name := range names {
@@ -97,18 +88,10 @@ func RegisterStream(provider string) {
 	streamProviders[provider] = struct{}{}
 }
 
-// RegisterToolStream records that provider can accept tool schemas in Stream
-// requests. This is intentionally separate from RegisterStream because some
-// providers can stream tokens but cannot expose tools while streaming.
-func RegisterToolStream(provider string) {
-	toolStreamProviders[provider] = struct{}{}
-}
-
 var streamProviders = make(map[string]struct{})
-var toolStreamProviders = make(map[string]struct{})
 
 // RegisteredProviders returns the registered provider names in sorted order.
-// kind may be "model", "image", "video", "stream", "tool_stream", or empty for the union of all
+// kind may be "model", "image", "video", "stream", or empty for the union of all
 // provider registries.
 func RegisteredProviders(kind string) []string {
 	names := map[string]struct{}{}
@@ -138,8 +121,6 @@ func RegisteredProviders(kind string) []string {
 		add(providers)
 	case "stream":
 		add(streamProviders)
-	case "tool_stream":
-		add(toolStreamProviders)
 	case "image":
 		add(imageProviders)
 	case "video":

ai/capabilities_test.go

@@ -44,14 +44,14 @@ func TestRegisteredProviders(t *testing.T) {
 func TestCapabilityRows(t *testing.T) {
 	got := ai.CapabilityRows()
 	want := []ai.CapabilityRow{
-		{Provider: "anthropic", Capabilities: ai.Capabilities{Model: true, Stream: true, ToolStream: true}},
+		{Provider: "anthropic", Capabilities: ai.Capabilities{Model: true, Stream: true}},
 		{Provider: "atlascloud", Capabilities: ai.Capabilities{Model: true, Image: true, Video: true, Stream: true}},
 		{Provider: "gemini", Capabilities: ai.Capabilities{Model: true}},
-		{Provider: "groq", Capabilities: ai.Capabilities{Model: true, Stream: true, ToolStream: true}},
-		{Provider: "minimax", Capabilities: ai.Capabilities{Model: true, Stream: true, ToolStream: true}},
-		{Provider: "mistral", Capabilities: ai.Capabilities{Model: true, Stream: true, ToolStream: true}},
-		{Provider: "openai", Capabilities: ai.Capabilities{Model: true, Image: true, Stream: true, ToolStream: true}},
-		{Provider: "together", Capabilities: ai.Capabilities{Model: true, Stream: true, ToolStream: true}},
+		{Provider: "groq", Capabilities: ai.Capabilities{Model: true, Stream: true}},
+		{Provider: "minimax", Capabilities: ai.Capabilities{Model: true, Stream: true}},
+		{Provider: "mistral", Capabilities: ai.Capabilities{Model: true, Stream: true}},
+		{Provider: "openai", Capabilities: ai.Capabilities{Model: true, Image: true, Stream: true}},
+		{Provider: "together", Capabilities: ai.Capabilities{Model: true, Stream: true}},
 	}
 	if !reflect.DeepEqual(got, want) {
 		t.Fatalf("CapabilityRows() = %#v, want %#v", got, want)
@@ -71,7 +71,7 @@ func TestCapabilityMatrix(t *testing.T) {
 		}
 	}
 
-	if caps := ai.ProviderCapabilities("openai"); caps != (ai.Capabilities{Model: true, Image: true, Stream: true, ToolStream: true}) {
+	if caps := ai.ProviderCapabilities("openai"); caps != (ai.Capabilities{Model: true, Image: true, Stream: true}) {
 		t.Fatalf("ProviderCapabilities(openai) = %#v", caps)
 	}
 	if caps := ai.ProviderCapabilities("atlascloud"); caps != (ai.Capabilities{Model: true, Image: true, Video: true, Stream: true}) {
@@ -95,17 +95,3 @@ func TestRegisterStream(t *testing.T) {
 		t.Fatalf("RegisteredProviders(stream) = %#v, want %#v", got, want)
 	}
 }
-
-func TestRegisterToolStream(t *testing.T) {
-	ai.RegisterToolStream("test-tool-stream")
-
-	if caps := ai.ProviderCapabilities("test-tool-stream"); caps != (ai.Capabilities{ToolStream: true}) {
-		t.Fatalf("ProviderCapabilities(test-tool-stream) = %#v", caps)
-	}
-
-	got := ai.RegisteredProviders("tool_stream")
-	want := []string{"anthropic", "groq", "minimax", "mistral", "openai", "test-tool-stream", "together"}
-	if !reflect.DeepEqual(got, want) {
-		t.Fatalf("RegisteredProviders(tool_stream) = %#v, want %#v", got, want)
-	}
-}

ai/groq/groq.go

@@ -30,7 +30,6 @@ func init() {
 		return NewProvider(opts...)
 	})
 	ai.RegisterStream("groq")
-	ai.RegisterToolStream("groq")
 }
 
 type Provider struct {

ai/minimax/minimax.go

@@ -30,7 +30,6 @@ func init() {
 		return NewProvider(opts...)
 	})
 	ai.RegisterStream("minimax")
-	ai.RegisterToolStream("minimax")
 }
 
 type Provider struct {

ai/mistral/mistral.go

@@ -30,7 +30,6 @@ func init() {
 		return NewProvider(opts...)
 	})
 	ai.RegisterStream("mistral")
-	ai.RegisterToolStream("mistral")
 }
 
 type Provider struct {

ai/ollama/ollama.go

@@ -45,7 +45,6 @@ func init() {
 		return NewProvider(opts...)
 	})
 	ai.RegisterStream("ollama")
-	ai.RegisterToolStream("ollama")
 }
 
 // Provider implements the ai.Model interface for Ollama.

ai/openai/openai.go

@@ -22,7 +22,6 @@ func init() {
 		return NewProvider(opts...)
 	})
 	ai.RegisterStream("openai")
-	ai.RegisterToolStream("openai")
 }
 
 // Provider implements the ai.Model interface for OpenAI

ai/retry.go

@@ -157,7 +157,7 @@ func GenerateWithRetry(ctx context.Context, m Model, req *Request, policy Genera
 			info.MaxAttempts = policy.MaxAttempts
 			callCtx = WithRunInfo(callCtx, info)
 		}
-		resp, err := generateAttempt(callCtx, m, req, opts...)
+		resp, err := m.Generate(callCtx, req, opts...)
 		cancel()
 
 		// Caller cancellation/deadline always wins and is not retried, even if
@@ -197,27 +197,6 @@ func GenerateWithRetry(ctx context.Context, m Model, req *Request, policy Genera
 	return nil, &RetryError{Attempts: policy.MaxAttempts, Kind: ClassifyError(last), Err: last}
 }
 
-func generateAttempt(ctx context.Context, m Model, req *Request, opts ...GenerateOption) (*Response, error) {
-	if err := ctx.Err(); err != nil {
-		return nil, err
-	}
-	type result struct {
-		resp *Response
-		err  error
-	}
-	done := make(chan result, 1)
-	go func() {
-		resp, err := m.Generate(ctx, req, opts...)
-		done <- result{resp: resp, err: err}
-	}()
-	select {
-	case res := <-done:
-		return res.resp, res.err
-	case <-ctx.Done():
-		return nil, ctx.Err()
-	}
-}
-
 func retryBackoff(err error, attempt int, base time.Duration) time.Duration {
 	backoff := base
 	if backoff <= 0 {

ai/retry_test.go

@@ -4,7 +4,6 @@ import (
 	"context"
 	"errors"
 	"net/http"
-	"sync/atomic"
 	"testing"
 	"time"
 )
@@ -70,9 +69,9 @@ func TestGenerateWithRetryDoesNotRetryCallerCancellation(t *testing.T) {
 }
 
 func TestGenerateWithRetryHonorsPerAttemptTimeout(t *testing.T) {
-	var attempts atomic.Int32
+	attempts := 0
 	model := retryModel{generate: func(ctx context.Context, _ *Request, _ ...GenerateOption) (*Response, error) {
-		attempts.Add(1)
+		attempts++
 		<-ctx.Done()
 		return nil, ctx.Err()
 	}}
@@ -92,8 +91,8 @@ func TestGenerateWithRetryHonorsPerAttemptTimeout(t *testing.T) {
 	if !errors.Is(err, context.DeadlineExceeded) {
 		t.Fatalf("error = %v, want context.DeadlineExceeded", err)
 	}
-	if got := attempts.Load(); got != 2 {
-		t.Fatalf("attempts = %d, want 2", got)
+	if attempts != 2 {
+		t.Fatalf("attempts = %d, want 2", attempts)
 	}
 }
 
@@ -136,34 +135,6 @@ func TestGenerateWithRetryAddsAttemptMetadataToRunInfo(t *testing.T) {
 	}
 }
 
-func TestGenerateWithRetryReturnsWhenProviderIgnoresTimeout(t *testing.T) {
-	started := make(chan struct{})
-	release := make(chan struct{})
-	model := retryModel{generate: func(ctx context.Context, req *Request, opts ...GenerateOption) (*Response, error) {
-		close(started)
-		<-release
-		return &Response{Reply: "late"}, nil
-	}}
-	defer close(release)
-
-	start := time.Now()
-	_, err := GenerateWithRetry(context.Background(), model, &Request{Prompt: "hi"}, GeneratePolicy{
-		Timeout:     10 * time.Millisecond,
-		MaxAttempts: 1,
-	})
-	if !errors.Is(err, context.DeadlineExceeded) {
-		t.Fatalf("GenerateWithRetry error = %v, want deadline exceeded", err)
-	}
-	if elapsed := time.Since(start); elapsed > 200*time.Millisecond {
-		t.Fatalf("GenerateWithRetry took %s after deadline, want prompt return", elapsed)
-	}
-	select {
-	case <-started:
-	default:
-		t.Fatal("provider was not called")
-	}
-}
-
 type statusErr int
 
 func (e statusErr) Error() string   { return "provider status" }

ai/together/together.go

@@ -30,7 +30,6 @@ func init() {
 		return NewProvider(opts...)
 	})
 	ai.RegisterStream("together")
-	ai.RegisterToolStream("together")
 }
 
 type Provider struct {

cmd/micro/README.md

@@ -67,11 +67,10 @@ provider-free agent path:
 ```
 micro agent demo
 micro examples
-micro zero-to-hero
 ```
 
 Those commands point at the smallest mock-model first-agent example, the no-secret
-transcript, and the 0→hero support app before you add provider-backed chat.
+transcript, and the support app before you add provider-backed chat.
 
 ### Output
 

cmd/micro/chat/chat.go

@@ -74,9 +74,7 @@ a new service automatically and start using it.
 
 Examples:
   ANTHROPIC_API_KEY=sk-ant-... micro chat --provider anthropic
-  micro chat --provider openai --prompt "list all users"
-  micro chat assistant --prompt "create a task"`,
-		ArgsUsage: "[agent]",
+  micro chat --provider openai --prompt "list all users"`,
 		Flags: []cli.Flag{
 			&cli.StringFlag{Name: "provider", Usage: "AI provider (anthropic, openai, gemini, groq, mistral, together, atlascloud)", EnvVars: []string{"MICRO_AI_PROVIDER"}},
 			&cli.StringFlag{Name: "api_key", Usage: "API key for the provider", EnvVars: []string{"MICRO_AI_API_KEY"}},
@@ -318,7 +316,6 @@ func run(c *cli.Context) error {
 	baseURL := c.String("base_url")
 	singlePrompt := c.String("prompt")
 	streamOutput := c.Bool("stream")
-	targetAgent := c.Args().First()
 
 	if provider == "" {
 		provider = ai.AutoDetectProvider(baseURL)
@@ -326,36 +323,15 @@ func run(c *cli.Context) error {
 	if apiKey == "" {
 		apiKey = fallbackAPIKey(provider)
 	}
+	if apiKey == "" {
+		return fmt.Errorf("no API key configured; set --api_key or %s", envVarForProvider(provider))
+	}
 
 	reg := registry.DefaultRegistry
 	cl := clt.DefaultClient
 
 	tools := ai.NewTools(reg, ai.ToolClient(cl))
 
-	s := &session{
-		provider: provider,
-		apiKey:   apiKey,
-		tools:    tools,
-		reg:      reg,
-		cl:       cl,
-		hist:     ai.NewHistory(50),
-		stream:   streamOutput,
-	}
-	hasAgents := s.discoverAgents()
-	if targetAgent != "" {
-		if _, ok := s.agents[targetAgent]; !ok {
-			return fmt.Errorf("agent %q is not registered; run `micro agent list` to see available agents", targetAgent)
-		}
-		s.agents = map[string]agentInfo{targetAgent: s.agents[targetAgent]}
-		hasAgents = true
-	}
-	if targetAgent != "" && singlePrompt != "" {
-		return s.ask(c.Context, singlePrompt)
-	}
-	if apiKey == "" {
-		return fmt.Errorf("no API key configured; set --api_key or %s", envVarForProvider(provider))
-	}
-
 	// Built-in agent capabilities (plan, delegate), reused from the
 	// agent package so the direct-service fallback matches a real agent.
 	builtinTools, builtinHandle := agent.Builtins(
@@ -367,8 +343,17 @@ func run(c *cli.Context) error {
 		agent.APIKey(apiKey),
 	)
 
-	s.builtinTools = builtinTools
-	s.builtinHandle = builtinHandle
+	s := &session{
+		provider:      provider,
+		apiKey:        apiKey,
+		tools:         tools,
+		reg:           reg,
+		cl:            cl,
+		hist:          ai.NewHistory(50),
+		builtinTools:  builtinTools,
+		builtinHandle: builtinHandle,
+		stream:        streamOutput,
+	}
 	s.refreshTools()
 
 	// Wrap the tool handler to intercept generate calls
@@ -402,6 +387,9 @@ func run(c *cli.Context) error {
 
 	defer s.cleanup()
 
+	// Discover registered agents
+	hasAgents := s.discoverAgents()
+
 	if singlePrompt != "" {
 		return s.ask(c.Context, singlePrompt)
 	}

cmd/micro/cli/new/contract_test.go

@@ -31,7 +31,7 @@ func TestZeroToOneContract(t *testing.T) {
 		}
 	}
 
-	generated.assertLocalModule(t)
+	generated.replaceModule(t)
 	generated.build(t)
 	generated.run(t)
 	generated.call(t, "Alice", "Hello Alice")
@@ -52,7 +52,7 @@ func TestZeroToOneNoMCPContract(t *testing.T) {
 		t.Fatalf("--no-mcp generated main.go with MCP wiring:\n%s", main)
 	}
 
-	generated.assertLocalModule(t)
+	generated.replaceModule(t)
 	generated.build(t)
 	generated.run(t)
 	generated.call(t, "Bob", "Hello Bob")
@@ -112,7 +112,6 @@ func generateService(t *testing.T, name string, args ...string) generatedService
 	if err != nil {
 		t.Fatal(err)
 	}
-	t.Setenv("MICRO_NEW_GO_MICRO_REPLACE", repoRoot)
 
 	tmp := t.TempDir()
 	oldwd, err := os.Getwd()
@@ -143,7 +142,7 @@ func generateService(t *testing.T, name string, args ...string) generatedService
 	return generatedService{dir: filepath.Join(tmp, name), repoRoot: repoRoot}
 }
 
-func (g generatedService) assertLocalModule(t *testing.T) {
+func (g generatedService) replaceModule(t *testing.T) {
 	t.Helper()
 
 	modPath := filepath.Join(g.dir, "go.mod")
@@ -151,9 +150,10 @@ func (g generatedService) assertLocalModule(t *testing.T) {
 	if err != nil {
 		t.Fatal(err)
 	}
-	want := "replace go-micro.dev/v6 => " + filepath.ToSlash(g.repoRoot)
-	if !strings.Contains(string(mod), want) {
-		t.Fatalf("generated go.mod missing local replace %q:\n%s", want, mod)
+	modText := strings.Replace(string(mod), "go-micro.dev/v6 latest", "go-micro.dev/v6 v6.0.0", 1)
+	modText += "\nreplace go-micro.dev/v6 => " + filepath.ToSlash(g.repoRoot) + "\n"
+	if err := os.WriteFile(modPath, []byte(modText), 0644); err != nil {
+		t.Fatal(err)
 	}
 }
 

cmd/micro/cli/new/new.go

@@ -39,8 +39,6 @@ type config struct {
 	UseGoPath bool
 	// MicroVersion is the go-micro version to require in go.mod
 	MicroVersion string
-	// MicroReplace optionally points generated services at a local go-micro checkout.
-	MicroReplace string
 	// Files
 	Files []file
 	// Comments
@@ -71,10 +69,6 @@ func microVersion() string {
 	return "latest"
 }
 
-func microReplace() string {
-	return filepath.ToSlash(os.Getenv("MICRO_NEW_GO_MICRO_REPLACE"))
-}
-
 type file struct {
 	Path string
 	Tmpl string
@@ -221,7 +215,6 @@ func Run(ctx *cli.Context) error {
 		GoPath:       goPath,
 		UseGoPath:    false,
 		MicroVersion: microVersion(),
-		MicroReplace: microReplace(),
 	}
 
 	if useProto {

cmd/micro/cli/new/template/module.go

@@ -10,9 +10,7 @@ require (
 	github.com/golang/protobuf latest
 	google.golang.org/protobuf latest
 )
-{{if .MicroReplace}}
-replace go-micro.dev/v6 => {{.MicroReplace}}
-{{end}}`
+`
 
 	// ModuleNoProto is the default go.mod: no protobuf dependencies.
 	// MicroVersion is the version this CLI was built from (or "latest"), so a
@@ -22,7 +20,5 @@ replace go-micro.dev/v6 => {{.MicroReplace}}
 go 1.23
 
 require go-micro.dev/v6 {{.MicroVersion}}
-{{if .MicroReplace}}
-replace go-micro.dev/v6 => {{.MicroReplace}}
-{{end}}`
+`
 )

cmd/micro/first_agent_walkthrough_test.go

@@ -41,7 +41,7 @@ func TestFirstAgentWalkthroughCLIBoundaries(t *testing.T) {
 	}
 
 	chat := commandByName(t, "chat")
-	if !strings.Contains(chat.Description, "services") || !strings.Contains(chat.Description, "agent") || !strings.Contains(chat.Description, `micro chat assistant --prompt`) {
+	if !strings.Contains(chat.Description, "services") || !strings.Contains(chat.Description, "agent") {
 		t.Fatalf("micro chat should describe the service-to-agent walkthrough boundary; description was %q", chat.Description)
 	}
 

cmd/micro/loop/templates/loop-release.yml.tmpl

@@ -1,11 +1,9 @@
 name: "Loop: Release"
 
-# Generated by `micro loop init`. Cuts the next tag when the default branch has
-# new commits since the latest one, and pushes it with a PAT (<< .TokenSecret >>)
-# so any tag-triggered release workflow fires. The bump reflects what shipped,
-# read from the CHANGELOG [Unreleased] section: new features (Added/Changed) cut
-# a MINOR; fixes/docs only cut a PATCH; breaking changes are skipped so a MAJOR
-# stays a human decision.
+# Generated by `micro loop init`. Cuts the next PATCH tag
+# (<< .TagPrefix >>MAJOR.MINOR.PATCH+1) when the default branch has new commits
+# since the latest such tag, and pushes it with a PAT (<< .TokenSecret >>) so any
+# tag-triggered release workflow fires. Minor/major bumps stay with a human.
 #
 # The tag MUST be pushed with a PAT, not the default GITHUB_TOKEN: a tag pushed
 # by GITHUB_TOKEN does not trigger other workflows (Actions blocks that recursion).
@@ -68,30 +66,11 @@ jobs:
             [0-9]*.[0-9]*.[0-9]*) ;;
             *) echo "unexpected tag shape: $LATEST" ; exit 1 ;;
           esac
-
-          # Choose the bump from what actually shipped, read from the CHANGELOG
-          # [Unreleased] section (kept current by the coherence role):
-          #   new features (### Added / ### Changed) -> MINOR
-          #   fixes/docs only                        -> PATCH
-          #   breaking (### Removed / "(breaking)")  -> skip; a major is a human call
-          UNRELEASED=""
-          if [ -f CHANGELOG.md ]; then
-            UNRELEASED=$(awk '/^## \[Unreleased\]/{f=1; next} /^## \[/{f=0} f' CHANGELOG.md)
-          fi
-          if printf '%s\n' "$UNRELEASED" | grep -qiE '^### Removed|^### Changed \(breaking\)|BREAKING'; then
-            echo "CHANGELOG [Unreleased] contains breaking changes — a major release is a human decision. Skipping."
-            exit 0
-          elif printf '%s\n' "$UNRELEASED" | grep -qE '^### (Added|Changed)'; then
-            NEXT="<< .TagPrefix >>${major}.$((minor + 1)).0"
-            KIND="minor (new features)"
-          else
-            NEXT="<< .TagPrefix >>${major}.${minor}.$((patch + 1))"
-            KIND="patch (fixes/docs only)"
-          fi
-          echo "cutting: $NEXT — $KIND ($COUNT commits since $LATEST)"
+          NEXT="<< .TagPrefix >>${major}.${minor}.$((patch + 1))"
+          echo "cutting: $NEXT ($COUNT commits since $LATEST)"
 
           git config user.name "loop release bot"
           git config user.email "noreply@users.noreply.github.com"
-          git tag -a "$NEXT" -m "Release $NEXT — automated $KIND ($COUNT commits since $LATEST)"
+          git tag -a "$NEXT" -m "Release $NEXT — automated patch ($COUNT commits since $LATEST)"
           git push "https://x-access-token:${RELEASE_TOKEN}@github.com/${REPO}.git" "$NEXT"
           echo "Pushed $NEXT."

internal/docs/AGENT_CONFORMANCE.md

@@ -17,7 +17,6 @@ provider API keys you want to exercise:
 | Atlas Cloud | `ATLASCLOUD_API_KEY` | `GO_MICRO_CONFORMANCE_ATLASCLOUD_MODEL` |
 | Gemini | `GEMINI_API_KEY` | `GO_MICRO_CONFORMANCE_GEMINI_MODEL` |
 | Groq | `GROQ_API_KEY` | `GO_MICRO_CONFORMANCE_GROQ_MODEL` |
-| MiniMax | `MINIMAX_API_KEY` | `GO_MICRO_CONFORMANCE_MINIMAX_MODEL` |
 | Mistral | `MISTRAL_API_KEY` | `GO_MICRO_CONFORMANCE_MISTRAL_MODEL` |
 | Together | `TOGETHER_API_KEY` | `GO_MICRO_CONFORMANCE_TOGETHER_MODEL` |
 

internal/harness/plan-delegate/main.go

@@ -503,10 +503,7 @@ func runPlanDelegate(provider string) error {
 		executeDone <- f.Execute(ctx, "launch readiness")
 	}()
 
-	if err := waitForPlanDelegateExecution(executeDone, taskSvc, notifySvc, func(ctx context.Context) error {
-		_, err := comms.Ask(ctx, "Recover the missing owner readiness notification now for the launch work already created. Send exactly one notification with this exact task: "+delegatedNotifyTask+" Use the notify service and do not create or modify tasks.")
-		return err
-	}); err != nil {
+	if err := waitForPlanDelegateExecution(executeDone, taskSvc, notifySvc); err != nil {
 		return err
 	}
 
@@ -516,7 +513,7 @@ func runPlanDelegate(provider string) error {
 	} else {
 		return fmt.Errorf("plan was not persisted")
 	}
-	if taskSvc.count() == 0 || notifySvc.count() != 1 {
+	if taskSvc.count() != 3 || notifySvc.count() != 1 {
 		return fmt.Errorf("unexpected side effects: tasks=%d notify=%d", taskSvc.count(), notifySvc.count())
 	}
 
@@ -529,7 +526,7 @@ func planDelegateConductorStep(conductor agent.Agent, taskSvc *TaskService, noti
 		prompt := "Create three launch tasks (Design, Build, Ship), then make sure owner@acme.com is notified: " + in.String()
 		rsp, err := conductor.Ask(ctx, prompt)
 		if err != nil {
-			if isUnfinishedPlanError(err) && taskSvc != nil && notifySvc != nil && taskSvc.count() > 0 && notifySvc.count() == 0 {
+			if isUnfinishedPlanError(err) && taskSvc != nil && notifySvc != nil && taskSvc.count() == 3 && notifySvc.count() == 0 {
 				fmt.Printf("\n\033[33mwarning:\033[0m conductor stopped with unfinished delegation after creating tasks; continuing to require-notify recovery: %v\n", err)
 				return in, nil
 			}
@@ -556,7 +553,7 @@ func requireDelegatedNotifyStep(taskSvc *TaskService, notifySvc *NotifyService,
 		if notify == 1 {
 			return in, nil
 		}
-		if recoverMissingNotify == nil || tasks == 0 || notify != 0 {
+		if recoverMissingNotify == nil || tasks != 3 || notify != 0 {
 			return in, fmt.Errorf("delegation completed without required notify side effect: notify=%d, want 1", notify)
 		}
 		settled, err := waitForNotifySideEffect(notifySvc, delegatedNotifySettleTimeout)
@@ -583,7 +580,7 @@ func requireDelegatedNotifyStep(taskSvc *TaskService, notifySvc *NotifyService,
 	}
 }
 
-func waitForPlanDelegateExecution(done <-chan error, taskSvc *TaskService, notifySvc *NotifyService, recoverMissingNotify func(context.Context) error) error {
+func waitForPlanDelegateExecution(done <-chan error, taskSvc *TaskService, notifySvc *NotifyService) error {
 	ticker := time.NewTicker(50 * time.Millisecond)
 	defer ticker.Stop()
 	for {
@@ -593,26 +590,12 @@ func waitForPlanDelegateExecution(done <-chan error, taskSvc *TaskService, notif
 			notify := notifySvc.count()
 			if err != nil {
 				if isClientTimeout(err) {
-					if tasks > 0 && notify == 1 {
+					if tasks == 3 && notify == 1 {
 						fmt.Printf("\n\033[33mwarning:\033[0m flow execute returned after completed side effects: %v\n", err)
 						return nil
 					}
 					return classifiedPlanDelegateTimeout(tasks, notify, err)
 				}
-				if isUnfinishedPlanError(err) && tasks > 0 && notify == 0 && recoverMissingNotify != nil {
-					fmt.Printf("\n\033[33mwarning:\033[0m flow stopped after partial plan side effects; recovering missing delegated notify: %v\n", err)
-					if recoverErr := recoverMissingNotify(context.Background()); recoverErr != nil {
-						return fmt.Errorf("flow execute after side effects tasks=%d notify=%d and recovery failed: %w", tasks, notify, recoverErr)
-					}
-					settled, waitErr := waitForNotifySideEffect(notifySvc, delegatedNotifySettleTimeout)
-					if waitErr != nil {
-						return waitErr
-					}
-					if settled {
-						return nil
-					}
-					return fmt.Errorf("flow execute after side effects tasks=%d notify=%d: delegation recovery completed without required notify side effect: notify=%d, want 1", tasks, notify, notifySvc.count())
-				}
 				return fmt.Errorf("flow execute after side effects tasks=%d notify=%d: %w", tasks, notify, err)
 			}
 			if notify != 1 {

internal/harness/plan-delegate/main_test.go

@@ -276,7 +276,7 @@ func TestPlanDelegateExecutionAcceptsDuplicateNotifyReplay(t *testing.T) {
 
 	done := make(chan error, 1)
 	done <- nil
-	if err := waitForPlanDelegateExecution(done, new(TaskService), notifySvc, nil); err != nil {
+	if err := waitForPlanDelegateExecution(done, new(TaskService), notifySvc); err != nil {
 		t.Fatalf("waitForPlanDelegateExecution returned %v, want duplicate replay accepted", err)
 	}
 	if got := notifySvc.count(); got != 1 {
@@ -287,42 +287,12 @@ func TestPlanDelegateExecutionAcceptsDuplicateNotifyReplay(t *testing.T) {
 	}
 }
 
-func TestPlanDelegateExecutionRecoversUnfinishedPlanAfterPartialTaskSideEffect(t *testing.T) {
-	taskSvc := new(TaskService)
-	var addRsp AddResponse
-	if err := taskSvc.Add(context.Background(), &AddRequest{Title: "Design"}, &addRsp); err != nil {
-		t.Fatalf("Add: %v", err)
-	}
-	notifySvc := new(NotifyService)
-	done := make(chan error, 1)
-	done <- errors.New("agent run abc has unfinished plan steps: Delegate readiness notification to comms agent")
-
-	recovered := false
-	err := waitForPlanDelegateExecution(done, taskSvc, notifySvc, func(ctx context.Context) error {
-		recovered = true
-		var sendRsp SendResponse
-		return notifySvc.Send(ctx, &SendRequest{To: "owner@acme.com", Message: "The launch plan is ready"}, &sendRsp)
-	})
-	if err != nil {
-		t.Fatalf("waitForPlanDelegateExecution returned %v, want partial notify recovery", err)
-	}
-	if !recovered {
-		t.Fatal("missing notify recovery did not run")
-	}
-	if got := taskSvc.count(); got != 1 {
-		t.Fatalf("task count = %d, want completed partial task to stay singular", got)
-	}
-	if got := notifySvc.count(); got != 1 {
-		t.Fatalf("notify count = %d, want recovered notify side effect", got)
-	}
-}
-
 func TestPlanDelegateExecutionRejectsClaimedCompletionWithoutNotify(t *testing.T) {
 	notifySvc := new(NotifyService)
 	done := make(chan error, 1)
 	done <- nil
 
-	err := waitForPlanDelegateExecution(done, new(TaskService), notifySvc, nil)
+	err := waitForPlanDelegateExecution(done, new(TaskService), notifySvc)
 	if err == nil {
 		t.Fatal("waitForPlanDelegateExecution returned nil, want missing notify side-effect error")
 	}
@@ -484,7 +454,7 @@ func TestPlanDelegateExecutionAcceptsClientTimeoutAfterSideEffects(t *testing.T)
 	done := make(chan error, 1)
 	done <- errors.New(`{"id":"go.micro.client","code":408,"detail":"<nil>","status":"Request Timeout"}`)
 
-	if err := waitForPlanDelegateExecution(done, taskSvc, notifySvc, nil); err != nil {
+	if err := waitForPlanDelegateExecution(done, taskSvc, notifySvc); err != nil {
 		t.Fatalf("waitForPlanDelegateExecution returned %v, want completed side effects to satisfy client timeout", err)
 	}
 }
@@ -493,7 +463,7 @@ func TestPlanDelegateExecutionClassifiesClientTimeoutBeforeSideEffects(t *testin
 	done := make(chan error, 1)
 	done <- errors.New(`{"id":"go.micro.client","code":408,"detail":"<nil>","status":"Request Timeout"}`)
 
-	err := waitForPlanDelegateExecution(done, new(TaskService), new(NotifyService), nil)
+	err := waitForPlanDelegateExecution(done, new(TaskService), new(NotifyService))
 	if err == nil {
 		t.Fatal("waitForPlanDelegateExecution returned nil, want timeout before side effects to fail")
 	}
@@ -520,7 +490,7 @@ func TestPlanDelegateExecutionClassifiesPartialClientTimeout(t *testing.T) {
 	done := make(chan error, 1)
 	done <- errors.New(`{"id":"go.micro.client","code":408,"detail":"<nil>","status":"Request Timeout"}`)
 
-	err := waitForPlanDelegateExecution(done, taskSvc, new(NotifyService), nil)
+	err := waitForPlanDelegateExecution(done, taskSvc, new(NotifyService))
 	if err == nil {
 		t.Fatal("waitForPlanDelegateExecution returned nil, want timeout before notify to fail")
 	}

internal/harness/provider-conformance/main.go

@@ -206,10 +206,10 @@ func writeSummaryMarkdown(path string, summary conformanceSummary) error {
 
 func capabilityMarkdown(rows []ai.CapabilityRow) string {
 	var b strings.Builder
-	b.WriteString("| Provider | Model | Image | Video | Streaming | Tool streaming |\n")
-	b.WriteString("| --- | --- | --- | --- | --- | --- |\n")
+	b.WriteString("| Provider | Model | Image | Video | Streaming |\n")
+	b.WriteString("| --- | --- | --- | --- | --- |\n")
 	for _, row := range rows {
-		fmt.Fprintf(&b, "| %s | %s | %s | %s | %s | %s |\n", row.Provider, mark(row.Model), mark(row.Image), mark(row.Video), mark(row.Stream), mark(row.ToolStream))
+		fmt.Fprintf(&b, "| %s | %s | %s | %s | %s |\n", row.Provider, mark(row.Model), mark(row.Image), mark(row.Video), mark(row.Stream))
 	}
 	return b.String()
 }
@@ -250,9 +250,9 @@ func mark(ok bool) string {
 
 func printCapabilityMatrix() {
 	fmt.Println("Provider capability matrix:")
-	fmt.Println("provider     model  image  video  stream  tool-stream")
+	fmt.Println("provider     model  image  video  stream")
 	for _, row := range ai.CapabilityRows() {
-		fmt.Printf("%-12s %-5s  %-5s  %-5s  %-6s  %-11s\n", row.Provider, yesNo(row.Model), yesNo(row.Image), yesNo(row.Video), yesNo(row.Stream), yesNo(row.ToolStream))
+		fmt.Printf("%-12s %-5s  %-5s  %-5s  %-6s\n", row.Provider, yesNo(row.Model), yesNo(row.Image), yesNo(row.Video), yesNo(row.Stream))
 	}
 	fmt.Println()
 }
@@ -421,7 +421,7 @@ func runAgentConformance(provider string, timeout time.Duration) error {
 	if provider == "mock" {
 		testProvider = "fake"
 	}
-	cmd := exec.CommandContext(ctx, "go", "test", "./agent", "-run", "TestAgentProvider(ConformanceMatrix|StreamConformanceMatrix)", "-count=1", "-v")
+	cmd := exec.CommandContext(ctx, "go", "test", "./agent", "-run", "TestAgentProviderConformanceMatrix", "-count=1", "-v")
 	cmd.Dir = repoRoot()
 	cmd.Stdout = os.Stdout
 	cmd.Stderr = os.Stderr

internal/harness/provider-conformance/main_test.go

@@ -93,7 +93,7 @@ func TestWriteCapabilityMarkdown(t *testing.T) {
 	}
 	got := string(b)
 	for _, want := range []string{
-		"| Provider | Model | Image | Video | Streaming | Tool streaming |",
+		"| Provider | Model | Image | Video | Streaming |",
 		"| mock | ✅ | — | — | — |",
 		"| vision | — | ✅ | ✅ | — |",
 	} {

internal/harness/zero-to-hero-ci/README.md

@@ -8,9 +8,9 @@ scripted so CI can run it on every push without external services or model keys.
 
 1. **Scaffold** — the maintained `micro new` 0→1 contract still creates
    runnable services from a clean workspace.
-2. **First agent** — `micro agent demo`, `micro examples`, `micro agent preflight`,
-   `micro run`, `micro chat`, and `micro inspect agent <name>` remain available
-   as the documented first-agent walkthrough path.
+2. **First agent** — `micro agent preflight`, `micro run`, `micro chat`, and
+   `micro inspect agent <name>` remain available as the documented first-agent
+   walkthrough path.
 3. **Run** — `micro run` remains available as the local development entry point.
 4. **Chat** — `micro chat` remains available as the interactive agent entry point.
 5. **Inspect/debugging** — `micro inspect agent <name>`, `micro agent history <name>`,
@@ -33,7 +33,7 @@ and A2A with only the LLM mocked.
 The default GitHub harness workflow runs this script on every push and pull
 request after the install smoke check and 0→1 scaffold contract. Developers can
 verify the first-agent on-ramp links alone with `make docs-wayfinding`, verify
-the installed first-run CLI seam alone with `make install-smoke`, run just the documented
+the installer seam alone with `make install-smoke`, run just the documented
 agent debugging quickcheck with
 `go test ./internal/harness/zero-to-hero-ci -run TestNoSecretFirstAgentDebuggingSmoke -count=1`,
 or run the same no-secret contract locally with:

internal/harness/zero-to-hero-ci/docs_test.go

@@ -20,7 +20,6 @@ func TestZeroToHeroReferenceDocs(t *testing.T) {
 	guide := readFile(t, filepath.Join(root, "internal", "website", "docs", "guides", "zero-to-hero.md"))
 	for _, want := range []string{
 		"make harness",
-		"make inner-loop",
 		"go test ./cmd/micro/cli/new -run TestZeroToOne -count=1",
 		"go test ./cmd/micro -run TestFirstAgentWalkthroughCLIBoundaries -count=1",
 		"go test ./cmd/micro -run TestZeroToHeroCLIBoundaries -count=1",
@@ -42,7 +41,7 @@ func TestZeroToHeroReferenceDocs(t *testing.T) {
 	runScript := readFile(t, filepath.Join(root, "internal", "harness", "zero-to-hero-ci", "run.sh"))
 	for _, want := range []string{
 		"go test ./cmd/micro/cli/new -run TestZeroToOne -count=1",
-		"go test ./cmd/micro -run 'TestFirstAgentWalkthroughCLIBoundaries|TestExamplesWayfindingIndexStaysLinked|TestExamplesCommandPointsAtWayfindingIndex|TestZeroToHeroCLIBoundaries|TestZeroToHeroCommandPrintsMaintainedNoSecretPath' -count=1",
+		"go test ./cmd/micro -run 'TestFirstAgentWalkthroughCLIBoundaries|TestZeroToHeroCLIBoundaries' -count=1",
 		"go test ./cmd/micro/cli/deploy -run TestDeployDryRun -count=1",
 		"go test ./examples/first-agent -run TestRunFirstAgent -count=1",
 		"go test ./examples/support -run 'TestRunSupportMockSmoke|TestZeroToHeroReadmeDocumentsLifecycle' -count=1",
@@ -51,27 +50,11 @@ func TestZeroToHeroReferenceDocs(t *testing.T) {
 			t.Fatalf("0→hero CI run script missing lifecycle command %q", want)
 		}
 	}
-	for _, want := range []string{
-		"scaffold:",
-		"run/chat/inspect:",
-		"deploy dry-run:",
-		"chat/inspect:",
-		"first-agent app:",
-		"0→hero app:",
-		"flow history:",
-	} {
-		if !strings.Contains(runScript, want) {
-			t.Fatalf("0→hero CI run script missing debuggable boundary label %q", want)
-		}
-	}
 
 	readme := readFile(t, filepath.Join(root, "README.md"))
 	if !strings.Contains(readme, "internal/website/docs/guides/zero-to-hero.md") {
 		t.Fatal("README does not point to the canonical 0→hero guide")
 	}
-	if !strings.Contains(readme, "make inner-loop") {
-		t.Fatal("README does not expose the focused CLI inner-loop contract")
-	}
 
 	nav := readFile(t, filepath.Join(root, "internal", "website", "_data", "navigation.yml"))
 	if !strings.Contains(nav, "0→hero Reference") || !strings.Contains(nav, "/docs/guides/zero-to-hero.html") {
@@ -289,12 +272,10 @@ func TestFirstAgentWayfindingDocs(t *testing.T) {
 			links: []string{
 				"internal/website/docs/guides/install-troubleshooting.md",
 				"micro agent demo",
-				"micro examples",
 				"micro zero-to-hero",
 				"internal/website/docs/guides/no-secret-first-agent.md",
 				"internal/website/docs/guides/your-first-agent.md",
 				"internal/website/docs/guides/debugging-agents.md",
-				"micro inspect agent <name>",
 				"internal/website/docs/guides/zero-to-hero.md",
 			},
 		},
@@ -316,26 +297,6 @@ func TestFirstAgentWayfindingDocs(t *testing.T) {
 				"./support/",
 			},
 		},
-		{
-			name:    "repository examples wayfinding index",
-			file:    filepath.Join(root, "examples", "INDEX.md"),
-			heading: "## Recommended adoption path",
-			links: []string{
-				"./hello-world/",
-				"./first-agent/",
-				"./support/",
-			},
-		},
-		{
-			name:    "micro README first-agent on-ramp",
-			file:    filepath.Join(root, "cmd", "micro", "README.md"),
-			heading: "## First agent on-ramp",
-			links: []string{
-				"micro agent demo",
-				"micro examples",
-				"micro zero-to-hero",
-			},
-		},
 		{
 			name:    "website examples index",
 			file:    filepath.Join(root, "internal", "website", "docs", "examples", "index.md"),
@@ -355,7 +316,6 @@ func TestFirstAgentWayfindingDocs(t *testing.T) {
 			links: []string{
 				"guides/install-troubleshooting.html",
 				"micro agent demo",
-				"micro examples",
 				"micro zero-to-hero",
 				"https://github.com/micro/go-micro/blob/master/examples/INDEX.md",
 				"https://github.com/micro/go-micro/tree/master/examples/support",
@@ -363,7 +323,6 @@ func TestFirstAgentWayfindingDocs(t *testing.T) {
 				"guides/no-secret-first-agent.html",
 				"guides/your-first-agent.html",
 				"guides/debugging-agents.html",
-				"micro inspect agent <name>",
 				"guides/zero-to-hero.html",
 			},
 		},
@@ -374,7 +333,6 @@ func TestFirstAgentWayfindingDocs(t *testing.T) {
 			links: []string{
 				"guides/install-troubleshooting.html",
 				"micro agent demo",
-				"micro examples",
 				"micro zero-to-hero",
 				"https://github.com/micro/go-micro/blob/master/examples/INDEX.md",
 				"https://github.com/micro/go-micro/tree/master/examples/support",
@@ -382,7 +340,6 @@ func TestFirstAgentWayfindingDocs(t *testing.T) {
 				"guides/no-secret-first-agent.html",
 				"guides/your-first-agent.html",
 				"guides/debugging-agents.html",
-				"micro inspect agent <name>",
 				"guides/zero-to-hero.html",
 			},
 		},
@@ -397,7 +354,6 @@ func TestFirstAgentWayfindingDocs(t *testing.T) {
 				"guides/no-secret-first-agent.html",
 				"guides/your-first-agent.html",
 				"guides/debugging-agents.html",
-				"micro inspect agent <name>",
 				"guides/zero-to-hero.html",
 			},
 		},
@@ -444,11 +400,6 @@ func TestFirstAgentWayfindingLinkTargetsResolve(t *testing.T) {
 			file:    filepath.Join(root, "examples", "README.md"),
 			heading: "## Recommended first-agent path",
 		},
-		{
-			name:    "repository examples wayfinding index",
-			file:    filepath.Join(root, "examples", "INDEX.md"),
-			heading: "## Recommended adoption path",
-		},
 		{
 			name:    "website examples index",
 			file:    filepath.Join(root, "internal", "website", "docs", "examples", "index.md"),
@@ -658,7 +609,6 @@ func TestGettingStartedDocsLeadWithNoSecretFirstRun(t *testing.T) {
 				"micro zero-to-hero",
 				"guides/no-secret-first-agent.html",
 				"guides/debugging-agents.html",
-				"micro inspect agent <name>",
 				"guides/zero-to-hero.html",
 			},
 		},

internal/harness/zero-to-hero-ci/run.sh

@@ -4,36 +4,17 @@ set -euo pipefail
 ROOT="$(cd "$(dirname "${BASH_SOURCE[0]}")/../../.." && pwd)"
 cd "$ROOT"
 
-run_step() {
-  local name=$1
-  shift
-
-  printf '\n==> %s\n' "$name"
-  printf '+ %q' "$@"
-  printf '\n'
-  "$@"
-}
-
 # Keep the developer inner-loop boundaries executable and discoverable in CI
-# without secrets or long-running daemons. Step names mirror the documented
-# install → scaffold → run/chat → inspect → deploy-dry-run seams so failures
-# identify the broken part of the getting-started contract.
-run_step "scaffold: 0→1 service contract" \
-  go test ./cmd/micro/cli/new -run TestZeroToOne -count=1
-run_step "run/chat/inspect: first-agent CLI boundaries" \
-  go test ./cmd/micro -run 'TestFirstAgentWalkthroughCLIBoundaries|TestExamplesWayfindingIndexStaysLinked|TestExamplesCommandPointsAtWayfindingIndex|TestZeroToHeroCLIBoundaries|TestZeroToHeroCommandPrintsMaintainedNoSecretPath' -count=1
-run_step "deploy dry-run: configured target plan" \
-  go test ./cmd/micro/cli/deploy -run TestDeployDryRun -count=1
-run_step "chat/inspect: no-secret first-agent transcript and docs" \
-  go test ./internal/harness/zero-to-hero-ci -run 'TestNoSecretFirstAgentTranscript|TestNoSecretFirstAgentDebuggingSmoke|TestZeroToHeroReferenceDocs|TestZeroToHeroDeployDryRunCommandSmoke|TestYourFirstAgentTutorialSmoke' -count=1
+# without secrets or long-running daemons.
+go test ./cmd/micro/cli/new -run TestZeroToOne -count=1
+go test ./cmd/micro -run 'TestFirstAgentWalkthroughCLIBoundaries|TestZeroToHeroCLIBoundaries' -count=1
+go test ./cmd/micro/cli/deploy -run TestDeployDryRun -count=1
+go test ./internal/harness/zero-to-hero-ci -run 'TestNoSecretFirstAgentTranscript|TestNoSecretFirstAgentDebuggingSmoke|TestZeroToHeroReferenceDocs|TestZeroToHeroDeployDryRunCommandSmoke|TestYourFirstAgentTutorialSmoke' -count=1
 
 # Deterministic no-secret reference scenarios. These use the real Go Micro
 # runtime and mock only the LLM provider. The support example is the maintained
 # runnable 0→hero app; keep it in this CI path so its documented run/chat/inspect
 # journey cannot drift from the framework.
-run_step "first-agent app: runnable provider-free example" \
-  go test ./examples/first-agent -run TestRunFirstAgent -count=1
-run_step "0→hero app: support lifecycle smoke" \
-  go test ./examples/support -run 'TestRunSupportMockSmoke|TestZeroToHeroReadmeDocumentsLifecycle' -count=1
-run_step "flow history: deterministic services → agents → workflows harnesses" \
-  go test ./internal/harness/universe ./internal/harness/plan-delegate -run 'Test.*Harness|TestPlanDelegateEndToEnd|TestPlanDelegateFlowHandoff' -count=1
+go test ./examples/first-agent -run TestRunFirstAgent -count=1
+go test ./examples/support -run 'TestRunSupportMockSmoke|TestZeroToHeroReadmeDocumentsLifecycle' -count=1
+go test ./internal/harness/universe ./internal/harness/plan-delegate -run 'Test.*Harness|TestPlanDelegateEndToEnd|TestPlanDelegateFlowHandoff' -count=1

internal/website/blog/34.md

@@ -1,45 +0,0 @@
----
-layout: blog
-title: "What's New in Go Micro: v6.3.15"
-permalink: /blog/34
-description: "Go Micro v6.3.15 tightens the first-agent on-ramp, adds Anthropic streaming, and hardens plan/delegate plus text tool-call recovery."
----
-
-# What's New in Go Micro: v6.3.15
-
-*July 5, 2026 • By the Go Micro Team*
-
-Go Micro v6.3.15 is a small but useful harness release: less friction for the first agent, better streaming provider coverage, and more reliable execution when models and delegates do not behave perfectly.
-
-## Anthropic now streams
-
-The Anthropic provider now supports Messages SSE streaming and is registered as a streaming-capable provider. That means Go Micro agents can use Anthropic in the same streaming path as the other streaming-capable providers, with request/response parser coverage and provider capability docs kept in sync.
-
-## The first-agent path is easier to start
-
-The on-ramp now has a smallest runnable first-agent example: a mock-model, no-secret agent you can run before adding provider keys. The CLI and docs also point new users toward the maintained first-agent path after scaffold/run milestones, so the next step after a service is clearer: run the example, build the agent, debug it, then walk the 0→hero services → agents → workflows path.
-
-## Plan/delegate is more deterministic
-
-Plan/delegate runs got another reliability pass. Completed plan steps are preserved, ordering is guarded, notify-before-completion is required in the flow path, and checkpoint continuation is more stable. These are the kinds of harness fixes that matter when an agent does real work over multiple tool calls instead of just answering a prompt.
-
-## Tool-call recovery keeps improving
-
-Provider text tool-call fallback paths now recover more of the awkward cases: tagged calls, `Create`-suffixed calls, mixed text/tool-call output, and AtlasCloud follow-up calls. The goal is pragmatic: when a weaker or non-standard provider emits something close to a tool call, the harness should still make progress when it can do so safely.
-
-## A2A payment groundwork
-
-The A2A gateway now has the shared payment-mandate foundation needed for AP2-style agent payment flows. It is groundwork, not a full product story yet, but it keeps Go Micro's agent interop and paid-tool direction moving together.
-
-## Read the changelog
-
-The full release notes are in the [CHANGELOG](https://github.com/micro/go-micro/blob/master/CHANGELOG.md).
-
----
-
-*Go Micro is an open source agent harness and service framework for Go. [Star us on GitHub](https://github.com/micro/go-micro).*
-
-<div class="post-nav">
-  <div><a href="/blog/33">&larr; The Loop, Shipped: Introducing micro loop</a></div>
-  <div><a href="/blog/">All Posts</a></div>
-</div>

internal/website/blog/index.html

@@ -11,13 +11,6 @@ permalink: /blog/
 
 <div class="posts">
 
-  <article style="margin-bottom: 2rem; padding-bottom: 1.5rem; border-bottom: 1px solid #e5e5e5;">
-    <h2 style="margin: 0 0 0.5rem;"><a href="/blog/34">What's New in Go Micro: v6.3.15</a></h2>
-    <p class="meta" style="color: #666; font-size: 0.85rem;">July 5, 2026</p>
-    <p>Go Micro v6.3.15 tightens the first-agent on-ramp, adds Anthropic streaming, hardens plan/delegate execution, and improves provider text tool-call recovery.</p>
-    <a href="/blog/34">Read more &rarr;</a>
-  </article>
-
   <article style="margin-bottom: 2rem; padding-bottom: 1.5rem; border-bottom: 1px solid #e5e5e5;">
     <h2 style="margin: 0 0 0.5rem;"><a href="/blog/33">The Loop, Shipped: Introducing micro loop</a></h2>
     <p class="meta" style="color: #666; font-size: 0.85rem;">July 2, 2026</p>

internal/website/docs/getting-started.md

@@ -63,7 +63,7 @@ After this quick start, follow the agent path in order:
 6. [Smallest first-agent example](https://github.com/micro/go-micro/tree/master/examples/first-agent) — run one service-backed agent with a mock model and no provider key.
 7. [No-secret first-agent transcript](guides/no-secret-first-agent.html) — run a useful support agent with a mock model before setting up a provider key.
 8. [Your First Agent](guides/your-first-agent.html) — build a service-backed agent and talk to it with `micro chat`.
-9. [Debugging your agent](guides/debugging-agents.html) — use `micro inspect agent <name>` to inspect service registration, tool calls, run history, memory, provider failures, and flow handoffs when the agent surprises you.
+9. [Debugging your agent](guides/debugging-agents.html) — inspect service registration, tool calls, run history, memory, provider failures, and flow handoffs when the agent surprises you.
 10. [0→hero reference path](guides/zero-to-hero.html) — prove the full scaffold → run → chat → inspect → deploy dry-run lifecycle with commands exercised by `make harness`.
 
 ## Write a Service

internal/website/docs/guides/ai-provider-guide.md

@@ -30,23 +30,23 @@ imports are linked in:
 
 ```go
 for _, row := range ai.CapabilityRows() {
-    fmt.Printf("%s: chat=%t image=%t video=%t stream=%t tool_stream=%t\n", row.Provider, row.Model, row.Image, row.Video, row.Stream, row.ToolStream)
+    fmt.Printf("%s: chat=%t image=%t video=%t stream=%t\n", row.Provider, row.Model, row.Image, row.Video, row.Stream)
 }
 ```
 
 The built-in providers currently register these capability interfaces:
 
-| Provider | Chat/text (`ai.Model`) | Image (`ai.ImageModel`) | Video (`ai.VideoModel`) | Streaming (`ai.Stream`) | Tool streaming |
-| --- | --- | --- | --- | --- | --- |
-| `anthropic` | Yes | No | No | Yes | Yes |
-| `atlascloud` | Yes | Yes | Yes | Yes | No |
-| `gemini` | Yes | No | No | No | No |
-| `groq` | Yes | No | No | Yes | Yes |
-| `minimax` | Yes | No | No | Yes | Yes |
-| `mistral` | Yes | No | No | Yes | Yes |
-| `ollama` | Yes | No | No | Yes | Yes |
-| `openai` | Yes | Yes | No | Yes | Yes |
-| `together` | Yes | No | No | Yes | Yes |
+| Provider | Chat/text (`ai.Model`) | Image (`ai.ImageModel`) | Video (`ai.VideoModel`) | Streaming (`ai.Stream`) |
+| --- | --- | --- | --- | --- |
+| `anthropic` | Yes | No | No | Yes |
+| `atlascloud` | Yes | Yes | Yes | Yes |
+| `gemini` | Yes | No | No | No |
+| `groq` | Yes | No | No | Yes |
+| `minimax` | Yes | No | No | Yes |
+| `mistral` | Yes | No | No | Yes |
+| `ollama` | Yes | No | No | Yes |
+| `openai` | Yes | Yes | No | Yes |
+| `together` | Yes | No | No | Yes |
 
 ## Step 1: Implement the `ai.Model` Interface
 

internal/website/docs/guides/provider_capabilities_test.go

@@ -34,7 +34,7 @@ func TestAIProviderGuideCapabilityMatrixMatchesRegistry(t *testing.T) {
 	guide := string(b)
 
 	for _, row := range ai.CapabilityRows() {
-		want := fmt.Sprintf("| `%s` | %s | %s | %s | %s | %s |", row.Provider, yesNo(row.Model), yesNo(row.Image), yesNo(row.Video), yesNo(row.Stream), yesNo(row.ToolStream))
+		want := fmt.Sprintf("| `%s` | %s | %s | %s | %s |", row.Provider, yesNo(row.Model), yesNo(row.Image), yesNo(row.Video), yesNo(row.Stream))
 		if !strings.Contains(guide, want) {
 			t.Fatalf("AI provider guide capability matrix is stale; missing row %q", want)
 		}

internal/website/docs/guides/zero-to-hero.md

@@ -69,12 +69,6 @@ SSH access, or remote service is required.
 
 ## Run focused checks while iterating
 
-Use the dedicated inner-loop target when you need the provider-free CLI contract in one focused command:
-
-```sh
-make inner-loop
-```
-
 Use the smaller checks when you are working on one seam:
 
 ```sh

internal/website/docs/index.md

@@ -16,14 +16,14 @@ It's built on a pluggable architecture of Go interfaces: service discovery, clie
 
 ## Learn More
 
-Start with [Getting Started](getting-started.html) for install and the first local service. Then follow the first-agent on-ramp in the same order as the README: `micro agent demo` for the installed no-secret CLI affordance, `micro examples` for the provider-free examples map, `micro zero-to-hero` for the maintained lifecycle harness, [examples wayfinding index](https://github.com/micro/go-micro/blob/master/examples/INDEX.md) for the runnable examples map, [the 0→hero support reference](https://github.com/micro/go-micro/tree/master/examples/support) for the full no-secret lifecycle example, [No-secret first-agent transcript](guides/no-secret-first-agent.html) to run a mock-model support agent, [Your First Agent](guides/your-first-agent.html) to build and chat with a service-backed agent, [Debugging your agent](guides/debugging-agents.html) to use `micro inspect agent <name>` for runs and memory, and the [0→hero reference path](guides/zero-to-hero.html) to walk the full scaffold → run → chat → inspect → deploy dry-run lifecycle covered by CI.
+Start with [Getting Started](getting-started.html) for install and the first local service. Then follow the first-agent on-ramp: `micro agent demo` for the installed no-secret CLI affordance, [examples wayfinding index](https://github.com/micro/go-micro/blob/master/examples/INDEX.md) for the maintained examples map, [the 0→hero support reference](https://github.com/micro/go-micro/tree/master/examples/support) for the full no-secret lifecycle example, [No-secret first-agent transcript](guides/no-secret-first-agent.html) to run a mock-model support agent, [Your First Agent](guides/your-first-agent.html) to build and chat with a service-backed agent, [Debugging your agent](guides/debugging-agents.html) to inspect runs and memory, and the [0→hero reference path](guides/zero-to-hero.html) to walk the full scaffold → run → chat → inspect → deploy dry-run lifecycle covered by CI.
 
 Otherwise continue to read the docs for more information about the framework.
 
 ## Contents
 
 - [Getting Started](getting-started.html)
-- [0→hero Reference](guides/zero-to-hero.html) - Walk scaffold → run → chat → `micro inspect agent <name>` → deploy dry-run with CI-backed commands
+- [0→hero Reference](guides/zero-to-hero.html) - Walk scaffold → run → chat → inspect → deploy dry-run with CI-backed commands
 - `micro agent demo` - Show the provider-free first-agent demo command and next docs steps
 - `micro examples` - Show provider-free first-agent examples in copy/paste order
 - [Examples wayfinding index](https://github.com/micro/go-micro/blob/master/examples/INDEX.md) - Choose the first-agent, support, and interop examples from one map
@@ -52,7 +52,7 @@ Otherwise continue to read the docs for more information about the framework.
 
 ## AI & Agents
 
-- [0→hero Reference](guides/zero-to-hero.html) - Walk scaffold → run → chat → `micro inspect agent <name>` → deploy dry-run with CI-backed commands
+- [0→hero Reference](guides/zero-to-hero.html) - Walk scaffold → run → chat → inspect → deploy dry-run with CI-backed commands
 - [No-secret first-agent transcript](guides/no-secret-first-agent.html) - Run the first useful agent path without a provider key
 - [Your First Agent](guides/your-first-agent.html) - Build a service-backed agent end to end
 - [Building AI-Native Services](guides/ai-native-services.html) - End-to-end tutorial for MCP-enabled services

internal/website/docs/quickstart.md

@@ -49,7 +49,7 @@ You now have the service half of the services → agents → workflows lifecycle
 6. **[Smallest first-agent example](https://github.com/micro/go-micro/tree/master/examples/first-agent)** - run a mock-model, no-secret agent before adding provider keys.
 7. **[No-secret first-agent transcript](guides/no-secret-first-agent.html)** - run a useful support agent with a mock model before setting up a provider key.
 8. **[Your First Agent](guides/your-first-agent.html)** - turn this service into an agent-callable tool, chat with it, and learn the `micro agent preflight` → `micro run` → `micro chat` loop.
-9. **[Debugging your agent](guides/debugging-agents.html)** - use `micro inspect agent <name>` to inspect service registration, tool calls, run history, memory, provider failures, and flow handoffs when the agent does something surprising.
+9. **[Debugging your agent](guides/debugging-agents.html)** - inspect service registration, tool calls, run history, memory, provider failures, and flow handoffs when the agent does something surprising.
 10. **[0→hero Reference](guides/zero-to-hero.html)** - walk the maintained scaffold → run → chat → inspect → deploy dry-run path that proves services, agents, and workflows together.
 
 After that first-agent path, branch out to:

internal/website/docs/roadmap.md

@@ -11,7 +11,7 @@ Go Micro is a framework for building **agents and services** in Go. An agent is
 The foundation is in place:
 
 - **Services** — register, discover, RPC, events; every endpoint is automatically an MCP tool.
-- **Agents** — a model with memory and tools that manages services, with `plan`, `delegate`, guardrails (`MaxSteps`, `LoopLimit`, `ApproveTool`), tool-execution middleware (`WrapTool`), run metadata, checkpoint/resume, and OpenTelemetry run spans built in.
+- **Agents** — a model with memory and tools that manages services, with `plan`, `delegate`, and guardrails (`MaxSteps`, `LoopLimit`, `ApproveTool`) built in, plus tool-execution middleware (`WrapTool`) and run metadata.
 - **Flows** — durable, event-driven workflows: ordered steps that checkpoint and resume after a crash.
 - **Interop** — the MCP gateway (services as tools) and the A2A gateway (agents as agents, both directions, including A2A streaming, push notifications, and multi-turn continuation), both generated from the registry; x402 for paid tools.
 - **Secure by default** — TLS verification on, state scoped per component.
@@ -34,24 +34,10 @@ The priority is that what exists works everywhere, under real conditions.
 - **Failure & resilience.** Provider timeouts, rate limits, and cancellation mid-run; deadline/`context` propagation through the agent loop; retry and backoff at the model call.
 - **The getting-started contract.** Define and CI-verify the 0→1 and 0→hero flows so they can't silently break.
 
-## Shipped agent depth
-
-- **Durable agent loop.** Opt-in `Checkpoint` support now lets agent `Ask` and
-  streaming runs persist, list pending work, and resume without replaying completed
-  tool calls. Human-input pauses resume through explicit input helpers.
-- **Agent observability.** `RunInfo` now feeds OpenTelemetry spans and events for
-  agent runs, model turns, tool calls, retries, delegation lineage, and resume
-  checkpoints so production runs are traceable.
-
 ## Next — agentic depth
 
 - **Streaming.** Broaden provider-backed `ai.Stream` coverage and keep chat plus A2A `message/stream` working end to end for real chat and long-task UX.
-- **Resume operations polish.** Keep improving CLI/docs breadcrumbs for finding
-  pending agent runs and deciding whether to call resume, resume-input, or stream
-  resume in production.
-- **Observability hardening.** Keep span attributes and run inspection coherent
-  across agents, flows, and gateways as more providers and workflow paths are
-  exercised.
+- **Agent observability.** Wire the new `RunInfo` into OpenTelemetry spans so a run — steps, tool calls, delegation — is traceable. This is also what anyone running it in production will need.
 
 ## Later
 

micro.go

@@ -215,10 +215,7 @@ func AgentWithCheckpoint(c Checkpoint) AgentOption { return agent.WithCheckpoint
 func AgentPending(ctx context.Context, a Agent) ([]FlowRun, error) { return agent.Pending(ctx, a) }
 
 // AgentResume resumes a checkpointed agent run by id. Completed runs return
-// the persisted response, including completed tool-call metadata, without
-// calling the model or replaying tool calls. Incomplete runs resume from the
-// saved prompt plus completed tool checkpoints; a provider call interrupted
-// mid-stream is retried rather than continued byte-for-byte.
+// the persisted response without calling the model or replaying tool calls.
 func AgentResume(ctx context.Context, a Agent, runID string) (*AgentResponse, error) {
 	return agent.Resume(ctx, a, runID)
 }