skip to content

detached 916fb78

test(subagents): wait for durable child state before reload

commit: 916fb780370bf2d1a5763af28bed1a7710662328
author: brice · 2mo ago · 2026-08-07 08:54 UTC
parent: 6f3e28f
signature: GPG VerifiedCD88F9E564E0102646FB6077A1A07C7C7C3E349D · arch-gpg Verified for the committer email

1 file · +10 -0

M packages/agent/subagents/batch_test.go +10 -0


@@ -58,6 +58,16 @@ func TestBatchReloadsDurableResult(t *testing.T) {
58	58		if want.Status != BatchSucceeded {
59	59		t.Fatalf("first batch status = %s", want.Status)
60	60		}
	61	+	// WaitBatch returns once the aggregate result is available, which can
	62	+	// precede each child's final metadata write. Wait for that finalisation
	63	+	// before another supervisor reloads the same durable state.
	64	+	for _, childID := range batch.ChildIDs {
	65	+	child := first.Get(childID)
	66	+	if child == nil {
	67	+	t.Fatalf("first supervisor is missing child %q", childID)
	68	+	}
	69	+	child.Wait()
	70	+	}
61	71
62	72		second := newSupervisor()
63	73		t.Cleanup(second.StopAll)


@@ -58,6 +58,16 @@ func TestBatchReloadsDurableResult(t *testing.T) {
58		if want.Status != BatchSucceeded {	58		if want.Status != BatchSucceeded {
59		t.Fatalf("first batch status = %s", want.Status)	59		t.Fatalf("first batch status = %s", want.Status)
60		}	60		}
			61	+	// WaitBatch returns once the aggregate result is available, which can
			62	+	// precede each child's final metadata write. Wait for that finalisation
			63	+	// before another supervisor reloads the same durable state.
			64	+	for _, childID := range batch.ChildIDs {
			65	+	child := first.Get(childID)
			66	+	if child == nil {
			67	+	t.Fatalf("first supervisor is missing child %q", childID)
			68	+	}
			69	+	child.Wait()
			70	+	}
61			71
62		second := newSupervisor()	72		second := newSupervisor()
63		t.Cleanup(second.StopAll)	73		t.Cleanup(second.StopAll)