[skip ci]Fix error log output format in task_scheduler.go (#13129)

Signed-off-by: JackLCL <chenglong.li@zilliz.com>
This commit is contained in:
JackLCL 2021-12-10 10:16:03 +08:00 committed by GitHub
parent 874c24862b
commit 554b7918e9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -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)