Merge pull request #64 from webitel/v24.04

AfterDistributeSchema fixed log
webitel · Jun 11, 2024 · 5ec6b79 · 5ec6b79
2 parents c88f4a0 + 9c351d2
commit 5ec6b79
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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_: