Skip to content

N
nodemanager
Commit f0cca9e2 authored by vicotor's avatar vicotor
Browse files
Options

update

parent e8c750dd
Hide whitespace changes
Inline Side-by-side
Showing with 5 additions and 0 deletions
server/worker.go
View file @ f0cca9e2
...@@ -421,6 +421,11 @@ func (w *Worker) doRunningModelStatus(msg *omanager.WorkerMessage_RunningModelSt ...@@ -421,6 +421,11 @@ func (w *Worker) doRunningModelStatus(msg *omanager.WorkerMessage_RunningModelSt
if err != nil { if err != nil {
log.WithError(err).Error("update worker running model status failed") log.WithError(err).Error("update worker running model status failed")
} }
// 2. update model exec time to worker running model.
err = w.runningOp.UpdateExecTime(context.TODO(), w.workerAddr, id, int(msg.RunningModelStatus.ExecTime))
if err != nil {
log.WithError(err).Error("update worker running model exec time failed")
}
} }
func (w *Worker) doGPUUsage(msg *omanager.WorkerMessage_GpuUsage) { func (w *Worker) doGPUUsage(msg *omanager.WorkerMessage_GpuUsage) {
......
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