Skip to content

Commit

Permalink
fix replay logic slightly
Browse files Browse the repository at this point in the history
  • Loading branch information
makramkd committed Jul 16, 2024
1 parent 78e622e commit e78b6ea
Showing 1 changed file with 4 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -177,12 +177,16 @@ func TestIntegration_OCR3Nodes(t *testing.T) {
replayBlock = endBlock
}
}
replayBlocks[chainID] = replayBlock
}

// replay the log poller on all the chains so that the logs are in the db.
// otherwise the plugins won't pick them up.
// TODO: this is happening too early, we need to wait for the chain readers to get their config
// and register the LP filters before this has any effect.
for _, node := range nodes {
for chainID, replayBlock := range replayBlocks {
t.Logf("Replaying logs for chain %d from block %d", chainID, replayBlock)
require.NoError(t, node.app.ReplayFromBlock(big.NewInt(int64(chainID)), replayBlock, false), "failed to replay logs")
}
}
Expand Down

0 comments on commit e78b6ea

Please sign in to comment.