We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 913e550 commit 4c9e964Copy full SHA for 4c9e964
pkg/scheduler/scheduler_test.go
@@ -267,7 +267,7 @@ func TestSchedulerShutdown_FrontendLoop(t *testing.T) {
267
frontendLoop := initFrontendLoop(t, frontendClient, "frontend-12345")
268
269
// Stop the scheduler. This will disable receiving new requests from frontends.
270
- scheduler.StopAsync()
+ require.NoError(t, services.StopAndAwaitTerminated(context.Background(), scheduler))
271
272
// We can still send request to scheduler, but we get shutdown error back.
273
require.NoError(t, frontendLoop.Send(&schedulerpb.FrontendToScheduler{
0 commit comments