From 6cced064ebc3fdd7d2b4af1cc93b2cf067c0dbba Mon Sep 17 00:00:00 2001 From: Gabriele Santomaggio Date: Mon, 20 Jan 2025 15:01:55 +0100 Subject: [PATCH] wait metadata Signed-off-by: Gabriele Santomaggio --- pkg/stream/producer_test.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/pkg/stream/producer_test.go b/pkg/stream/producer_test.go index 688a72fb..45b480bb 100644 --- a/pkg/stream/producer_test.go +++ b/pkg/stream/producer_test.go @@ -592,6 +592,9 @@ var _ = Describe("Streaming Producers", func() { "it should receive some message") Expect(env.DeleteStream(prodErrorStream)).NotTo(HaveOccurred()) + // This test does not use production code. It is used only to simulate the publish error + // it gives the time to update the medata. that is not valid in this test + time.Sleep(500 * time.Millisecond) Expect(env.Close()).NotTo(HaveOccurred()) })