Skip to content

Commit

Permalink
disttask: fix hang in make ut (pingcap#49406)
Browse files Browse the repository at this point in the history
  • Loading branch information
ywqzzy authored Dec 13, 2023
1 parent fc2e10b commit f7d2de0
Showing 1 changed file with 7 additions and 1 deletion.
8 changes: 7 additions & 1 deletion pkg/disttask/framework/testutil/context.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,9 @@ import (
"sync/atomic"
"testing"

"github.com/pingcap/failpoint"
"github.com/pingcap/tidb/pkg/testkit"
"github.com/stretchr/testify/require"
"github.com/tikv/client-go/v2/util"
"go.uber.org/mock/gomock"
)
Expand All @@ -40,7 +42,11 @@ func InitTestContext(t *testing.T, nodeNum int) (context.Context, *gomock.Contro
ctrl := gomock.NewController(t)
defer ctrl.Finish()
ctx := context.Background()
ctx = util.WithInternalSourceType(ctx, "scheduler")
ctx = util.WithInternalSourceType(ctx, "dispatcher")
require.NoError(t, failpoint.Enable("github.com/pingcap/tidb/pkg/util/cpu/mockNumCpu", "return(8)"))
t.Cleanup(func() {
require.NoError(t, failpoint.Disable("github.com/pingcap/tidb/pkg/util/cpu/mockNumCpu"))
})

return ctx, ctrl, &TestContext{}, testkit.NewDistExecutionContext(t, nodeNum)
}

0 comments on commit f7d2de0

Please sign in to comment.