diff --git a/lib/lambda_ethereum_consensus/p2p/blob_downloader.ex b/lib/lambda_ethereum_consensus/p2p/blob_downloader.ex
index 0e0291495..6888ba9aa 100644
--- a/lib/lambda_ethereum_consensus/p2p/blob_downloader.ex
+++ b/lib/lambda_ethereum_consensus/p2p/blob_downloader.ex
@@ -53,7 +53,7 @@ defmodule LambdaEthereumConsensus.P2P.BlobDownloader do
 
         if retries > 0 do
           Logger.debug("Retrying request for #{count} blobs", slot: slot)
-          request_blobs_by_range(slot, count, retries - 1)
+          request_blobs_by_range(slot, count, on_blobs, retries - 1)
         else
           on_blobs.({:error, reason})
         end
@@ -99,7 +99,7 @@ defmodule LambdaEthereumConsensus.P2P.BlobDownloader do
 
         if retries > 0 do
           Logger.debug("Retrying request for blobs.")
-          request_blobs_by_root(identifiers, retries - 1)
+          request_blobs_by_root(identifiers, on_blobs, retries - 1)
         else
           on_blobs.({:error, reason})
         end
diff --git a/lib/lambda_ethereum_consensus/p2p/block_downloader.ex b/lib/lambda_ethereum_consensus/p2p/block_downloader.ex
index de021a330..702f7a84b 100644
--- a/lib/lambda_ethereum_consensus/p2p/block_downloader.ex
+++ b/lib/lambda_ethereum_consensus/p2p/block_downloader.ex
@@ -143,7 +143,7 @@ defmodule LambdaEthereumConsensus.P2P.BlockDownloader do
           :telemetry.execute([:network, :request], %{blocks: 0}, Map.put(tags, :result, "retry"))
           pretty_roots = Enum.map_join(roots, ", ", &Base.encode16/1)
           Logger.debug("Retrying request for blocks with roots #{pretty_roots}")
-          request_blocks_by_root(roots, retries - 1)
+          request_blocks_by_root(roots, on_blocks, retries - 1)
         else
           :telemetry.execute([:network, :request], %{blocks: 0}, Map.put(tags, :result, "error"))
           on_blocks.({:error, reason})