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())
 
 	})