|
|
@@ -23,7 +23,7 @@ import (
|
|
|
|
|
|
// 判断用户等待队列中的任务是否可以加入到集群等待队列
|
|
|
func RunWaitingUser() {
|
|
|
-
|
|
|
+ infra.GlobalLogger.Infof("启动【用户等待队列】监控进程。")
|
|
|
for {
|
|
|
time.Sleep(2 * time.Second)
|
|
|
global.RunTaskMutex.Lock()
|
|
|
@@ -64,6 +64,7 @@ func RunWaitingUser() {
|
|
|
|
|
|
// 集群等待队列中的任务判断是否可以加入集群运行队列
|
|
|
func RunWaitingCluster() {
|
|
|
+ infra.GlobalLogger.Infof("启动【集群等待队列】监控进程。")
|
|
|
for {
|
|
|
time.Sleep(2 * time.Second)
|
|
|
global.GpuNodeListMutex.Lock()
|
