коммит произвёл
GitHub
родитель
7bb23323d1
Коммит
b810a40062
@@ -107,10 +107,10 @@ func TestScheduler(t *testing.T) {
|
|||||||
jobServer.HandleClusterLeaderChange(false)
|
jobServer.HandleClusterLeaderChange(false)
|
||||||
jobServer.StartSchedulers()
|
jobServer.StartSchedulers()
|
||||||
time.Sleep(time.Second)
|
time.Sleep(time.Second)
|
||||||
|
jobServer.StopSchedulers()
|
||||||
for _, element := range jobServer.schedulers.nextRunTimes {
|
for _, element := range jobServer.schedulers.nextRunTimes {
|
||||||
assert.Nil(t, element)
|
assert.Nil(t, element)
|
||||||
}
|
}
|
||||||
jobServer.StopSchedulers()
|
|
||||||
})
|
})
|
||||||
|
|
||||||
t.Run("DoubleClusterLeaderChangedBeforeStart", func(t *testing.T) {
|
t.Run("DoubleClusterLeaderChangedBeforeStart", func(t *testing.T) {
|
||||||
@@ -119,10 +119,10 @@ func TestScheduler(t *testing.T) {
|
|||||||
jobServer.HandleClusterLeaderChange(true)
|
jobServer.HandleClusterLeaderChange(true)
|
||||||
jobServer.StartSchedulers()
|
jobServer.StartSchedulers()
|
||||||
time.Sleep(time.Second)
|
time.Sleep(time.Second)
|
||||||
|
jobServer.StopSchedulers()
|
||||||
for _, element := range jobServer.schedulers.nextRunTimes {
|
for _, element := range jobServer.schedulers.nextRunTimes {
|
||||||
assert.NotNil(t, element)
|
assert.NotNil(t, element)
|
||||||
}
|
}
|
||||||
jobServer.StopSchedulers()
|
|
||||||
})
|
})
|
||||||
|
|
||||||
t.Run("ConfigChanged", func(t *testing.T) {
|
t.Run("ConfigChanged", func(t *testing.T) {
|
||||||
|
|||||||
Ссылка в новой задаче
Block a user