From a78f244621b1d5c3ba40bd2ab064211d19b56a1f Mon Sep 17 00:00:00 2001 From: jochen Date: Sat, 24 Oct 2026 19:09:54 +0200 Subject: [PATCH] Assert the controller's buckets before the served test's fixture writes the chain (issue 1945) --- cmd/mesh-controller/composed_served_integration_test.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/cmd/mesh-controller/composed_served_integration_test.go b/cmd/mesh-controller/composed_served_integration_test.go index f87ff74b..9c722061 100644 --- a/cmd/mesh-controller/composed_served_integration_test.go +++ b/cmd/mesh-controller/composed_served_integration_test.go @@ -148,6 +148,15 @@ func aServedMesh(t *testing.T) *servedMesh { t.Fatal(err) } t.Cleanup(chainConn.Close) + // The controller's own buckets, the chain's among them, as it asserts them at its start. + asserter, err := broker.Dial(u.String()) + if err != nil { + t.Fatal(err) + } + t.Cleanup(asserter.Close) + if err := asserter.EnsureControllerBuckets(); err != nil { + t.Fatalf("the controller's buckets: %v", err) + } c, err := chain.OnTheBus(ctx, chainConn, func(context.Context) error { return nil }) if err != nil { t.Fatal(err)