update

pingcap · May 15, 2023 · 76f8c68 · 76f8c68
1 parent fc6f1e6
commit 76f8c68
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/disttask/framework/dispatcher/dispatcher.go b/disttask/framework/dispatcher/dispatcher.go
@@ -64,7 +64,7 @@ type TaskHandle interface {
 	// GetAllSchedulerIDs gets handles the task's all scheduler instances.
 	GetAllSchedulerIDs(ctx context.Context, gTaskID int64) ([]string, error)
 	// GetPreviousSubtaskMetas gets previous subtask metas.
-	GetPreviousSubtaskMetas(ctx context.Context, gTaskID int64, step int64) ([][]byte, error)
+	GetPreviousSubtaskMetas(gTaskID int64, step int64) ([][]byte, error)
 }
 
 func (d *dispatcher) getRunningGTaskCnt() int {
@@ -483,7 +483,7 @@ func (d *dispatcher) GetAllSchedulerIDs(ctx context.Context, gTaskID int64) ([]s
 	return ids, nil
 }
 
-func (d *dispatcher) GetPreviousSubtaskMetas(ctx context.Context, gTaskID int64, step int64) ([][]byte, error) {
+func (d *dispatcher) GetPreviousSubtaskMetas(gTaskID int64, step int64) ([][]byte, error) {
 	previousSubtasks, err := d.taskMgr.GetSucceedSubtasksByStep(gTaskID, step)
 	if err != nil {
 		logutil.BgLogger().Warn("get previous succeed subtask failed", zap.Int64("ID", gTaskID), zap.Int64("step", step))