diff --git a/internal/querycoord/task_scheduler.go b/internal/querycoord/task_scheduler.go index 5fd9a0ac96..f0cf8fc304 100644 --- a/internal/querycoord/task_scheduler.go +++ b/internal/querycoord/task_scheduler.go @@ -263,7 +263,7 @@ func (scheduler *TaskScheduler) unmarshalTask(taskID UniqueID, t string) (task, header := commonpb.MsgHeader{} err := proto.Unmarshal([]byte(t), &header) if err != nil { - return nil, fmt.Errorf("Failed to unmarshal message header, err %s ", err.Error()) + return nil, fmt.Errorf("failed to unmarshal message header, err %s ", err.Error()) } var newTask task baseTask := newBaseTask(scheduler.ctx, querypb.TriggerCondition_grpcRequest)