skip to content

detached be0c47d

fix(subagents): stabilize trace retention test

commit: be0c47d657394fbf821d1eae4362472f42ca4123
author: brice · 2mo ago · 2026-08-12 07:15 UTC
parent: a753677
signature: GPG VerifiedCD88F9E564E0102646FB6077A1A07C7C7C3E349D · arch-gpg Verified for the committer email

1 file · +8 -0

M packages/agent/subagents/trace_test.go +8 -0


@@ -76,6 +76,14 @@ func TestMemoryTraceWriterRetainsOrderedEventsWithoutBundle(t *testing.T) {
76	76		writer := NewMemoryTraceWriter()
77	77		for index := 0; index < memoryTraceEventLimit+2; index++ {
78	78		writer.Record(TraceEvent{Type: "event", Data: map[string]any{"index": index}})
	79	+	// Keep this retention test independent from the separate bounded-queue
	80	+	// contract: a slow Windows race run can otherwise intentionally drop
	81	+	// records before the in-memory limit is exercised.
	82	+	if (index+1)%traceQueueInitialCapacity == 0 {
	83	+	if err := writer.Flush(); err != nil {
	84	+	t.Fatal(err)
	85	+	}
	86	+	}
79	87		}
80	88		if err := writer.Flush(); err != nil {
81	89		t.Fatal(err)


@@ -76,6 +76,14 @@ func TestMemoryTraceWriterRetainsOrderedEventsWithoutBundle(t *testing.T) {
76		writer := NewMemoryTraceWriter()	76		writer := NewMemoryTraceWriter()
77		for index := 0; index < memoryTraceEventLimit+2; index++ {	77		for index := 0; index < memoryTraceEventLimit+2; index++ {
78		writer.Record(TraceEvent{Type: "event", Data: map[string]any{"index": index}})	78		writer.Record(TraceEvent{Type: "event", Data: map[string]any{"index": index}})
			79	+	// Keep this retention test independent from the separate bounded-queue
			80	+	// contract: a slow Windows race run can otherwise intentionally drop
			81	+	// records before the in-memory limit is exercised.
			82	+	if (index+1)%traceQueueInitialCapacity == 0 {
			83	+	if err := writer.Flush(); err != nil {
			84	+	t.Fatal(err)
			85	+	}
			86	+	}
79		}	87		}
80		if err := writer.Flush(); err != nil {	88		if err := writer.Flush(); err != nil {
81		t.Fatal(err)	89		t.Fatal(err)