diff --git a/pkg/solana/logpoller/loader.go b/pkg/solana/logpoller/loader.go
index 8b9444219..65e1cacfe 100644
--- a/pkg/solana/logpoller/loader.go
+++ b/pkg/solana/logpoller/loader.go
@@ -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
 	}
@@ -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:
 		}
 	}