Cleanup TestConcurrentQueries (#940)

m3db · Sep 25, 2018 · 3f28d90 · 3f28d90
1 parent c73fe84
commit 3f28d90
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/src/m3ninx/search/proptest/concurrent_test.go b/src/m3ninx/search/proptest/concurrent_test.go
@@ -65,13 +65,14 @@ func TestConcurrentQueries(t *testing.T) {
 			require.NoError(t, err)
 
 			var (
-				wg       sync.WaitGroup
-				errLock  sync.Mutex
-				matchErr error
+				numConcurrentWorkers = 2
+				wg                   sync.WaitGroup
+				errLock              sync.Mutex
+				matchErr             error
 			)
-			wg.Add(2)
+			wg.Add(numConcurrentWorkers)
 
-			for i := 0; i < 2; i++ {
+			for i := 0; i < numConcurrentWorkers; i++ {
 				go func() {
 					defer wg.Done()
 					fstDocs, err := fstExec.Execute(q)