Skip to content

Commit

Permalink
address comments
Browse files Browse the repository at this point in the history
  • Loading branch information
EasterTheBunny committed Nov 12, 2024
1 parent 47df208 commit 2534f47
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion pkg/solana/logpoller/loader.go
Original file line number Diff line number Diff line change
Expand Up @@ -225,7 +225,7 @@ func (c *EncodedLogCollector) loadRange(ctx context.Context, start, end uint64)
if err := c.loadSlotBlocksRange(ctx, start, end); err != nil {
// a retry will happen anyway on the next round of slots
// so the error is handled by doing nothing
c.lggr.Error("failed to load slot blocks range", "start", start, "end", end, "err", err)
c.lggr.Errorw("failed to load slot blocks range", "start", start, "end", end, "err", err)

return
}
Expand Down Expand Up @@ -253,6 +253,7 @@ func (c *EncodedLogCollector) loadSlotBlocksRange(ctx context.Context, start, en
for _, block := range result {
select {
case <-ctx.Done():
return nil
case c.chBlock <- block:
}
}
Expand Down

0 comments on commit 2534f47

Please sign in to comment.