diff --git a/protocol-units/da/movement/protocol/da/src/lib.rs b/protocol-units/da/movement/protocol/da/src/lib.rs index a28cf7779..b1f802d23 100644 --- a/protocol-units/da/movement/protocol/da/src/lib.rs +++ b/protocol-units/da/movement/protocol/da/src/lib.rs @@ -70,16 +70,7 @@ where &self, height: u64, ) -> Pin>, DaError>> + Send + '_>> { - Box::pin(async move { - let result = self.get_da_blobs_at_height(height).await; - match result { - Ok(blobs) => Ok(blobs), - Err(e) => { - warn!("failed to get blobs at height: {}", e); - Ok(vec![]) - } - } - }) + self.get_da_blobs_at_height(height) } fn stream_certificates(