diff --git a/internal/querycoord/task.go b/internal/querycoord/task.go index a7b33d9496..f726e88110 100644 --- a/internal/querycoord/task.go +++ b/internal/querycoord/task.go @@ -183,6 +183,7 @@ func (bt *BaseTask) Reschedule(ctx context.Context) ([]task, error) { return nil, nil } +// State returns the state of task, such as taskUndo, taskDoing, taskDone, taskExpired, taskFailed func (bt *BaseTask) State() taskState { bt.stateMu.RLock() defer bt.stateMu.RUnlock()