From 61d681387f0ce9cbfb1ab74c6e17de9278e31c34 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Wojciech=20Tyczy=C5=84ski?= <wojtekt@google.com>
Date: Wed, 4 May 2022 13:59:47 +0200
Subject: [PATCH] Close events recording sink in integration tests

---
 test/integration/util/util.go | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/test/integration/util/util.go b/test/integration/util/util.go
index 7b34f2dc341..abe42f2e362 100644
--- a/test/integration/util/util.go
+++ b/test/integration/util/util.go
@@ -424,8 +424,7 @@ func InitTestSchedulerWithOptions(
 		t.Fatalf("Couldn't create scheduler: %v", err)
 	}
 
-	stopCh := make(chan struct{})
-	eventBroadcaster.StartRecordingToSink(stopCh)
+	eventBroadcaster.StartRecordingToSink(testCtx.Ctx.Done())
 
 	return testCtx
 }