Skip to content

Commit

Permalink
try
Browse files Browse the repository at this point in the history
  • Loading branch information
p0mvn committed Oct 2, 2024
1 parent c5ca1d8 commit 9f20750
Showing 1 changed file with 7 additions and 2 deletions.
9 changes: 7 additions & 2 deletions ingest/indexer/service/blockprocessor/pair_publisher.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,8 @@ import (

sdk "github.com/cosmos/cosmos-sdk/types"

storetypes "cosmossdk.io/store/types"

"github.com/osmosis-labs/osmosis/osmomath"
commondomain "github.com/osmosis-labs/osmosis/v26/ingest/common/domain"
"github.com/osmosis-labs/osmosis/v26/ingest/indexer/domain"
Expand Down Expand Up @@ -49,7 +51,10 @@ func (p PairPublisher) PublishPoolPairs(ctx sdk.Context, pools []poolmanagertype

// Publish all the pools
for _, pool := range pools {
go func(pool poolmanagertypes.PoolI) {

go func(pool poolmanagertypes.PoolI, ctx sdk.Context) {
ctx = ctx.WithGasMeter(storetypes.NewInfiniteGasMeter())

denoms := pool.GetPoolDenoms(ctx)

mu.RLock()
Expand Down Expand Up @@ -156,7 +161,7 @@ func (p PairPublisher) PublishPoolPairs(ctx sdk.Context, pools []poolmanagertype
}

result <- nil
}(pool)
}(pool, ctx)
}

// Wait for all the results
Expand Down

0 comments on commit 9f20750

Please sign in to comment.