From 9c351d256405f441680768af743b0e2de7b9f443 Mon Sep 17 00:00:00 2001 From: "i.navrotskyj" Date: Tue, 11 Jun 2024 17:36:36 +0300 Subject: [PATCH] AfterDistributeSchema fixed log --- queue/schema.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/queue/schema.go b/queue/schema.go index 02a9cbbc..bbeb0346 100644 --- a/queue/schema.go +++ b/queue/schema.go @@ -213,11 +213,11 @@ func (qm *QueueManager) AfterDistributeSchema(att *Attempt) (*model.SchemaResult if err != nil { // TODO - wlog.Error(fmt.Sprintf("AfterDistributeSchema error: %s duration=%s", err.Error(), time.Since(st))) + wlog.Error(fmt.Sprintf("AfterDistributeSchema [%d] error: %s duration=%s", att.Id(), err.Error(), time.Since(st))) return nil, false } - att.Log(fmt.Sprintf("AfterDistributeSchema job_id=%s duration=%s", res.Id, time.Since(st))) + att.Log(fmt.Sprintf("AfterDistributeSchema [%d] job_id=%s duration=%s", att.Id(), res.Id, time.Since(st))) switch v := res.Result.(type) { case *flow.ResultAttemptResponse_Success_: