File tree Expand file tree Collapse file tree 2 files changed +16
-11
lines changed
aggregation_mode/src/backend Expand file tree Collapse file tree 2 files changed +16
-11
lines changed Original file line number Diff line number Diff line change @@ -97,13 +97,14 @@ impl ProofsFetcher {
9797 ) ;
9898
9999 // Download batch proofs from s3
100- let data = match get_aligned_batch_from_s3_with_multiple_urls ( batch. batchDataPointer ) . await {
101- Ok ( data) => data,
102- Err ( err) => {
103- error ! ( "Error while downloading proofs from s3. Err {:?}" , err) ;
104- continue ;
105- }
106- } ;
100+ let data =
101+ match get_aligned_batch_from_s3_with_multiple_urls ( batch. batchDataPointer ) . await {
102+ Ok ( data) => data,
103+ Err ( err) => {
104+ error ! ( "Error while downloading proofs from s3. Err {:?}" , err) ;
105+ continue ;
106+ }
107+ } ;
107108
108109 info ! ( "Data downloaded from S3, number of proofs {}" , data. len( ) ) ;
109110
Original file line number Diff line number Diff line change 1- use tracing:: { info, warn} ;
21use aligned_sdk:: common:: types:: VerificationData ;
2+ use tracing:: { info, warn} ;
33
44#[ derive( Debug ) ]
55#[ allow( dead_code) ]
@@ -21,12 +21,16 @@ pub async fn get_aligned_batch_from_s3_with_multiple_urls(
2121) -> Result < Vec < VerificationData > , GetBatchProofsError > {
2222 // Parse comma-separated URLs and limit to max 5
2323 let parsed_urls = parse_batch_urls ( & urls) ;
24- info ! ( "Getting batch from data service with {} URLs: {:?}" , parsed_urls. len( ) , parsed_urls) ;
25-
24+ info ! (
25+ "Getting batch from data service with {} URLs: {:?}" ,
26+ parsed_urls. len( ) ,
27+ parsed_urls
28+ ) ;
29+
2630 let mut errors = Vec :: new ( ) ;
2731
2832 // Try each URL until first successful response
29- for ( _i , url) in parsed_urls. iter ( ) . enumerate ( ) {
33+ for url in parsed_urls. iter ( ) {
3034 match get_aligned_batch_from_s3 ( url. clone ( ) ) . await {
3135 Ok ( data) => {
3236 return Ok ( data) ;
You can’t perform that action at this time.
0 commit comments