From 81bb52b08ca8fec45e1389f63cd32b98416e5c75 Mon Sep 17 00:00:00 2001
From: "lion.zhao" <lion.zhao@liulishuo.com>
Date: Wed, 10 Jun 2020 19:51:57 +0800
Subject: [PATCH] processor: log detail err in markAsDone func

---
 processor.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/processor.go b/processor.go
index f2bb1af..4b2f03b 100644
--- a/processor.go
+++ b/processor.go
@@ -253,7 +253,7 @@ func (p *processor) requeue(msg *base.TaskMessage) {
 func (p *processor) markAsDone(msg *base.TaskMessage) {
 	err := p.broker.Done(msg)
 	if err != nil {
-		errMsg := fmt.Sprintf("Could not remove task id=%s type=%q from %q", msg.ID, msg.Type, base.InProgressQueue)
+		errMsg := fmt.Sprintf("Could not remove task id=%s type=%q from %q err: %+v", msg.ID, msg.Type, base.InProgressQueue, err)
 		p.logger.Warnf("%s; Will retry syncing", errMsg)
 		p.syncRequestCh <- &syncRequest{
 			fn: func() error {