diff --git a/services/rfq/relayer/inventory/manager.go b/services/rfq/relayer/inventory/manager.go index 931bc084f1..04fbea754d 100644 --- a/services/rfq/relayer/inventory/manager.go +++ b/services/rfq/relayer/inventory/manager.go @@ -455,7 +455,7 @@ func (i *inventoryManagerImpl) HasSufficientGas(parentCtx context.Context, chain span.SetAttributes(attribute.String("gas_value", gasValue.String())) } - gasBalance, err := i.GetCommittableBalance(ctx, chainID, util.EthAddress) + gasBalance, err := i.GetCommittableBalance(ctx, chainID, util.EthAddress, SkipDBCache()) if err != nil { return false, fmt.Errorf("error getting committable gas on origin: %w", err) } diff --git a/services/rfq/relayer/service/handlers.go b/services/rfq/relayer/service/handlers.go index dbba3dea6e..07b3360be2 100644 --- a/services/rfq/relayer/service/handlers.go +++ b/services/rfq/relayer/service/handlers.go @@ -217,7 +217,7 @@ func (q *QuoteRequestHandler) commitPendingBalance(ctx context.Context, span tra defer unlocker.Unlock() // get destination committable balance - committableBalance, err := q.Inventory.GetCommittableBalance(ctx, int(q.Dest.ChainID), request.Transaction.DestToken) + committableBalance, err := q.Inventory.GetCommittableBalance(ctx, int(q.Dest.ChainID), request.Transaction.DestToken, inventory.SkipDBCache()) if errors.Is(err, inventory.ErrUnsupportedChain) { // don't process request if chain is currently unsupported span.AddEvent("dropping unsupported chain") @@ -626,7 +626,7 @@ func (q *QuoteRequestHandler) handleNotEnoughInventory(ctx context.Context, span defer unlocker.Unlock() // commit destination balance - committableBalance, err := q.Inventory.GetCommittableBalance(ctx, int(q.Dest.ChainID), request.Transaction.DestToken) + committableBalance, err := q.Inventory.GetCommittableBalance(ctx, int(q.Dest.ChainID), request.Transaction.DestToken, inventory.SkipDBCache()) if err != nil { return fmt.Errorf("could not get committable balance: %w", err) }