Close events recording sink in integration tests

2022-05-04 13:59:47 +02:00
parent f0791b5014
commit 61d681387f
1 changed files with 1 additions and 2 deletions
--- 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
 }