opensource/cloudpods
3
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-09-24 16:03:43 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(scheduler): unsued key

Browse Source
This commit is contained in:
Zexi Li
2024-02-28 10:26:50 +08:00
parent 52b08e6e3e
commit 7cbff93e0d
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/scheduler/manager/task_queue.go
+2 -3
View File
@@ -231,14 +231,13 @@ func (teqm *TaskExecutorQueueManager) GetQueue(schedType string) *TaskExecutorQu
defer teqm.lock.Unlock()
var (
key string
taskExecutorQueue *TaskExecutorQueue
ok bool
)
if taskExecutorQueue, ok = teqm.taskExecutorMap[key]; !ok {
if taskExecutorQueue, ok = teqm.taskExecutorMap[schedType]; !ok {
taskExecutorQueue = NewTaskExecutorQueue(schedType, teqm.stopCh)
teqm.taskExecutorMap[key] = taskExecutorQueue
teqm.taskExecutorMap[schedType] = taskExecutorQueue
}
return taskExecutorQueue