Commit dba82059 authored by duanjinfei's avatar duanjinfei

report task id

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