mirror of
https://github.com/newnius/YAO-scheduler.git
synced 2025-12-15 16:16:44 +00:00
update
This commit is contained in:
@@ -252,7 +252,9 @@ func (pool *ResourcePool) update(node NodeStatus) {
|
|||||||
|
|
||||||
if _, ok := pool.subscriptions[gpu.UUID]; ok {
|
if _, ok := pool.subscriptions[gpu.UUID]; ok {
|
||||||
for jobName := range pool.subscriptions[gpu.UUID] {
|
for jobName := range pool.subscriptions[gpu.UUID] {
|
||||||
scheduler.QueryState(jobName)
|
go func(name string) {
|
||||||
|
scheduler.QueryState(name)
|
||||||
|
}(jobName)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user