race in test
This commit is contained in:
+5
-5
@@ -1062,12 +1062,12 @@ func TestScheduler_WithDistributed(t *testing.T) {
|
|||||||
schedulersDone := make(chan struct{}, tt.count)
|
schedulersDone := make(chan struct{}, tt.count)
|
||||||
|
|
||||||
for i := tt.count; i > 0; i-- {
|
for i := tt.count; i > 0; i-- {
|
||||||
go func() {
|
s, err := newTestScheduler(
|
||||||
s, err := newTestScheduler(
|
tt.opt,
|
||||||
tt.opt,
|
)
|
||||||
)
|
require.NoError(t, err)
|
||||||
require.NoError(t, err)
|
|
||||||
|
|
||||||
|
go func() {
|
||||||
s.Start()
|
s.Start()
|
||||||
|
|
||||||
_, err = s.NewJob(
|
_, err = s.NewJob(
|
||||||
|
|||||||
Reference in New Issue
Block a user