@@ -73,7 +73,7 @@ func (k *keeper) prunePrices(ctx sdk.Context, cutoff time.Time, maxDelete int64)
7373
7474// pruneSourcePrices deletes price records for a single (source, denom, baseDenom)
7575// prefix that are older than cutoff. Returns number of records deleted.
76- func (k * keeper ) pruneSourcePrices (ctx sdk.Context , source uint32 , denom , baseDenom string , cutoff time.Time , maxDelete int64 ) int64 {
76+ func (k * keeper ) pruneSourcePrices (ctx sdk.Context , source uint32 , denom , baseDenom string , cutoff time.Time , maxDelete int64 ) ( int64 , error ) {
7777 start := types.PriceDataRecordID {
7878 Source : source ,
7979 Denom : denom ,
@@ -95,17 +95,21 @@ func (k *keeper) pruneSourcePrices(ctx sdk.Context, source uint32, denom, baseDe
9595 var toDelete []types.PriceDataRecordID
9696 var count int64
9797
98- _ = k .prices .Walk (ctx , rng , func (key types.PriceDataRecordID , _ types.PriceDataState ) (bool , error ) {
98+ if err : =k .prices .Walk (ctx , rng , func (key types.PriceDataRecordID , _ types.PriceDataState ) (bool , error ) {
9999 toDelete = append (toDelete , key )
100100 count ++
101101 return count >= maxDelete , nil
102- })
102+ }); err != nil {
103+ return count , err
104+ }
103105
104106 for _ , key := range toDelete {
105- _ = k .prices .Remove (ctx , key )
107+ if err := k .prices .Remove (ctx , key ); err != nil {
108+ return count , err
109+ }
106110 }
107111
108- return count
112+ return count , nil
109113}
110114
111115// EpochHooks returns the oracle keeper as an EpochHooks implementation for
0 commit comments