Commit 8beef215 authored by duanjinfei's avatar duanjinfei

report task id

parent 98c3e693
......@@ -182,7 +182,9 @@ func monitorWorker(op *operate.DockerOp) {
msgRespWorker.RegisterMsgResp(nodeManager, worker, RegisterInfoResp, nil)
time.Sleep(time.Second * 2)
msgRespWorker.RegisterMsgResp(nodeManager, worker, DeviceInfoResp, nil)
op.ModelTaskIdIndexesChan <- op.ReportTaskIds
if len(op.ReportTaskIds) == 0 {
op.ModelTaskIdIndexesChan <- []uint64{0}
}
isSend = true
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