disttask: add sleep when subtask == nil (pingcap#47668)

ref pingcap#46258
wuhuizuo · Apr 2, 2024 · 0e70df9 · 0e70df9
1 parent b566ecc
commit 0e70df9
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/disttask/framework/scheduler/scheduler.go b/pkg/disttask/framework/scheduler/scheduler.go
@@ -219,6 +219,7 @@ func (s *BaseScheduler) run(ctx context.Context, task *proto.Task) error {
 			if newTask.Step != task.Step || newTask.State != task.State {
 				break
 			}
+			time.Sleep(checkTime)
 			continue
 		}