Skip to content

Commit 333aac3

Browse files
authored
Fix: init default-queue failed when queue is already exist (#666) (#680)
* fix bug that init default-queue failed when queue is already exist * update queue when queue is already exist * fix location update
1 parent 1368e91 commit 333aac3

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

pkg/apiserver/controller/queue/queue.go

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@ import (
2323

2424
log "github.com/sirupsen/logrus"
2525
"gorm.io/gorm"
26+
k8serrors "k8s.io/apimachinery/pkg/api/errors"
2627
"volcano.sh/apis/pkg/apis/scheduling/v1beta1"
2728

2829
"github.com/PaddlePaddle/PaddleFlow/pkg/apiserver/common"
@@ -326,6 +327,15 @@ func CreateQueue(ctx *logger.RequestContext, request *CreateQueueRequest) (Creat
326327
}
327328

328329
err = runtimeSvc.CreateQueue(&queueInfo)
330+
if err != nil && k8serrors.IsAlreadyExists(err) {
331+
_, err = UpdateQueue(ctx, &UpdateQueueRequest{
332+
Name: request.Name,
333+
Namespace: request.Namespace,
334+
MaxResources: request.MaxResources,
335+
MinResources: request.MinResources,
336+
QuotaType: request.QuotaType,
337+
})
338+
}
329339
if err != nil {
330340
ctx.Logging().Errorf("GlobalVCQueue create request failed. error:%s", err.Error())
331341
ctx.ErrorCode = common.QueueResourceNotMatch

0 commit comments

Comments
 (0)