From c8ab780edbdd55cfd6e9f4dd775bf08b2db7c28f Mon Sep 17 00:00:00 2001 From: Abu Kashem Date: Wed, 13 Aug 2025 16:35:35 -0400 Subject: [PATCH] dra plugin: assume claim after api call in bindClaim --- .../plugins/dynamicresources/dynamicresources.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go b/pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go index df33e286ae0..7f6c4ddca9f 100644 --- a/pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go +++ b/pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go @@ -1469,12 +1469,13 @@ func (pl *DynamicResources) bindClaim(ctx context.Context, state *stateData, ind if pollErr != nil { logger.V(5).Info("Claim not stored in assume cache after retries", "claim", klog.KObj(claim), "err", pollErr) } - } - } else { - if err := pl.draManager.ResourceClaims().AssumeClaimAfterAPICall(claim); err != nil { - logger.V(5).Info("Claim not stored in assume cache", "err", err) + } else { + if err := pl.draManager.ResourceClaims().AssumeClaimAfterAPICall(claim); err != nil { + logger.V(5).Info("Claim not stored in assume cache", "err", err) + } } } + for _, claimUID := range claimUIDs { pl.draManager.ResourceClaims().RemoveClaimPendingAllocation(claimUID) }