scheduler: fix the issue that some scheduler persist config without s…

…olving error (#2817) Signed-off-by: lhy1024 <[email protected]>
tikv · Aug 21, 2020 · b35148e · b35148e
1 parent d40341c
commit b35148e
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 8 deletions.
diff --git a/plugin/scheduler_example/evict_leader.go b/plugin/scheduler_example/evict_leader.go
@@ -131,8 +131,7 @@ func (conf *evictLeaderSchedulerConfig) Persist() error {
 	if err != nil {
 		return err
 	}
-	conf.storage.SaveScheduleConfig(name, data)
-	return nil
+	return conf.storage.SaveScheduleConfig(name, data)
 }
 
 func (conf *evictLeaderSchedulerConfig) getScheduleName() string {

diff --git a/server/schedulers/evict_leader.go b/server/schedulers/evict_leader.go
@@ -119,8 +119,7 @@ func (conf *evictLeaderSchedulerConfig) Persist() error {
 	if err != nil {
 		return err
 	}
-	conf.storage.SaveScheduleConfig(name, data)
-	return nil
+	return conf.storage.SaveScheduleConfig(name, data)
 }
 
 func (conf *evictLeaderSchedulerConfig) getSchedulerName() string {

diff --git a/server/schedulers/grant_leader.go b/server/schedulers/grant_leader.go
@@ -114,8 +114,7 @@ func (conf *grantLeaderSchedulerConfig) Persist() error {
 	if err != nil {
 		return err
 	}
-	conf.storage.SaveScheduleConfig(name, data)
-	return nil
+	return conf.storage.SaveScheduleConfig(name, data)
 }
 
 func (conf *grantLeaderSchedulerConfig) getSchedulerName() string {

diff --git a/server/schedulers/scatter_range.go b/server/schedulers/scatter_range.go
@@ -110,8 +110,7 @@ func (conf *scatterRangeSchedulerConfig) Persist() error {
 	if err != nil {
 		return err
 	}
-	conf.storage.SaveScheduleConfig(name, data)
-	return nil
+	return conf.storage.SaveScheduleConfig(name, data)
 }
 
 func (conf *scatterRangeSchedulerConfig) GetRangeName() string {