TRKJ/EdgeNode
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeNode.git synced 2025-11-07 18:50:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

修复无法回报任务执行失败的问题

Browse Source
This commit is contained in:
GoEdgeLab
2022-11-05 14:56:57 +08:00
parent e4ae4dd0be
commit f17d1b4d99
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
internal/nodes/node.go
View File

@@ -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 { if taskId <= 0 {
return return
} }
@@ -465,10 +465,10 @@ func (this *Node) finishTask(taskId int64, err error) {
var nodeCtx = rpcClient.Context() var nodeCtx = rpcClient.Context()
var isOk = err == nil var isOk = taskErr == nil
var errMsg = "" var errMsg = ""
if err != nil { if taskErr != nil {
errMsg = err.Error() errMsg = taskErr.Error()
} }
_, err = rpcClient.NodeTaskRPC.ReportNodeTaskDone(nodeCtx, &pb.ReportNodeTaskDoneRequest{ _, err = rpcClient.NodeTaskRPC.ReportNodeTaskDone(nodeCtx, &pb.ReportNodeTaskDoneRequest{