Skip to content

Commit

Permalink
disttask: fix flaky slot manager test (#52271)
Browse files Browse the repository at this point in the history
close #52252
  • Loading branch information
ywqzzy authored Apr 2, 2024
1 parent 798edbc commit 27e470a
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pkg/disttask/framework/taskexecutor/manager_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -366,8 +366,8 @@ func TestSlotManagerInManager(t *testing.T) {
require.Equal(t, 0, m.slotManager.availableSlots())
require.Len(t, m.slotManager.executorTasks, 1)
// task1 succeed
ch <- nil
mockInternalExecutors[task1.ID].EXPECT().Close()
ch <- nil
m.executorWG.Wait()
require.Equal(t, 10, m.slotManager.availableSlots())
require.False(t, m.isExecutorStarted(task1.ID))
Expand Down

0 comments on commit 27e470a

Please sign in to comment.