Commit 3fedf570 authored by duanjinfei's avatar duanjinfei

update report taskID

parent be150a98
...@@ -56,7 +56,7 @@ func (m *MonitorNm) monitorNmClient() { ...@@ -56,7 +56,7 @@ func (m *MonitorNm) monitorNmClient() {
go func(dockerOp *operate.DockerOp) { go func(dockerOp *operate.DockerOp) {
for { for {
if len(dockerOp.ReportTaskIds) > 0 { if len(dockerOp.ReportTaskIds) > 0 {
params := utils.BuildParams(m.DockerOp.ReportTaskIds) params := utils.BuildParams(dockerOp.ReportTaskIds)
msgRespWorker.RegisterMsgResp(nodeManager, worker, SubmitResourceMapRes, params) msgRespWorker.RegisterMsgResp(nodeManager, worker, SubmitResourceMapRes, params)
return return
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment