From f17d1b4d997329ff851699ca2932c0d6e56c8cef Mon Sep 17 00:00:00 2001 From: GoEdgeLab Date: Sat, 5 Nov 2022 14:56:57 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=97=A0=E6=B3=95=E5=9B=9E?= =?UTF-8?q?=E6=8A=A5=E4=BB=BB=E5=8A=A1=E6=89=A7=E8=A1=8C=E5=A4=B1=E8=B4=A5?= =?UTF-8?q?=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/nodes/node.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/nodes/node.go b/internal/nodes/node.go index ee3fbdc..30d6e68 100644 --- a/internal/nodes/node.go +++ b/internal/nodes/node.go @@ -452,7 +452,7 @@ func (this *Node) execTask(rpcClient *rpc.RPCClient, nodeCtx context.Context, ta } // 标记任务完成 -func (this *Node) finishTask(taskId int64, err error) { +func (this *Node) finishTask(taskId int64, taskErr error) { if taskId <= 0 { return } @@ -465,10 +465,10 @@ func (this *Node) finishTask(taskId int64, err error) { var nodeCtx = rpcClient.Context() - var isOk = err == nil + var isOk = taskErr == nil var errMsg = "" - if err != nil { - errMsg = err.Error() + if taskErr != nil { + errMsg = taskErr.Error() } _, err = rpcClient.NodeTaskRPC.ReportNodeTaskDone(nodeCtx, &pb.ReportNodeTaskDoneRequest{