Commit 7c333c0d authored by duanjinfei's avatar duanjinfei

report task id

parent 8beef215
...@@ -184,6 +184,8 @@ func monitorWorker(op *operate.DockerOp) { ...@@ -184,6 +184,8 @@ func monitorWorker(op *operate.DockerOp) {
msgRespWorker.RegisterMsgResp(nodeManager, worker, DeviceInfoResp, nil) msgRespWorker.RegisterMsgResp(nodeManager, worker, DeviceInfoResp, nil)
if len(op.ReportTaskIds) == 0 { if len(op.ReportTaskIds) == 0 {
op.ModelTaskIdIndexesChan <- []uint64{0} op.ModelTaskIdIndexesChan <- []uint64{0}
} else {
op.ModelTaskIdIndexesChan <- op.ReportTaskIds
} }
isSend = true isSend = true
log.Info("------------------------Send once-off message ended------------------------") log.Info("------------------------Send once-off message ended------------------------")
......
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