diff --git a/src/resource_pool.go b/src/resource_pool.go index cd74d6a..b7935e6 100644 --- a/src/resource_pool.go +++ b/src/resource_pool.go @@ -252,7 +252,9 @@ func (pool *ResourcePool) update(node NodeStatus) { if _, ok := pool.subscriptions[gpu.UUID]; ok { for jobName := range pool.subscriptions[gpu.UUID] { - scheduler.QueryState(jobName) + go func(name string) { + scheduler.QueryState(name) + }(jobName) } } }