From 3c98adfe41d46c19820421974d5973ab52c4fea1 Mon Sep 17 00:00:00 2001 From: godchen Date: Mon, 4 Oct 2021 17:18:56 +0800 Subject: [PATCH] Handle util funcutil returned error (#9170) Signed-off-by: godchen --- internal/util/funcutil/parallel_test.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/internal/util/funcutil/parallel_test.go b/internal/util/funcutil/parallel_test.go index 0d42101fb0..395c069f88 100644 --- a/internal/util/funcutil/parallel_test.go +++ b/internal/util/funcutil/parallel_test.go @@ -104,9 +104,12 @@ func Test_ProcessFuncParallel(t *testing.T) { return nil } - ProcessFuncParallel(total, 1, randomErrorF, "randomErrorF") // serial + err = ProcessFuncParallel(total, 1, randomErrorF, "randomErrorF") // serial + assert.NotNil(t, err) - ProcessFuncParallel(total, total, randomErrorF, "randomErrorF") // Totally Parallel + err = ProcessFuncParallel(total, total, randomErrorF, "randomErrorF") // Totally Parallel + assert.NotNil(t, err) - ProcessFuncParallel(total, runtime.NumCPU(), randomErrorF, "randomErrorF") // Parallel by CPU + err = ProcessFuncParallel(total, runtime.NumCPU(), randomErrorF, "randomErrorF") // Parallel by CPU + assert.NotNil(t, err) }