1+ #![ allow( clippy:: type_complexity) ]
12use anyhow:: Context ;
23use async_trait:: async_trait;
34use chrono:: Utc ;
@@ -252,7 +253,7 @@ impl IndexProvider for FsIndexProvider {
252253 let mut results = Vec :: with_capacity ( index_keys. len ( ) ) ;
253254
254255 let mut crate_versions_with_publish =
255- get_latest_crate_publishes ( Arc :: clone ( & self . fs ) , index_keys) ? ;
256+ get_latest_crate_publishes ( Arc :: clone ( & self . fs ) , index_keys) ;
256257
257258 while let Some ( handle) = crate_versions_with_publish. join_next ( ) . await {
258259 let publish_fetch_result = handle. context ( "index fetch task unexpectedly failed" ) ?;
@@ -279,7 +280,7 @@ impl IndexProvider for FsIndexProvider {
279280 let mut results = Vec :: with_capacity ( index_keys. len ( ) ) ;
280281
281282 let mut crate_versions_with_publish =
282- get_latest_crate_publishes ( Arc :: clone ( & self . fs ) , index_keys) ? ;
283+ get_latest_crate_publishes ( Arc :: clone ( & self . fs ) , index_keys) ;
283284
284285 while let Some ( handle) = crate_versions_with_publish. join_next ( ) . await {
285286 let Ok ( Ok ( ( mut versions, publish_meta) ) ) = handle else { continue } ;
@@ -301,7 +302,7 @@ impl IndexProvider for FsIndexProvider {
301302fn get_latest_crate_publishes (
302303 fs : Arc < dyn MetadataStorageProvider + Send + Sync > ,
303304 index_keys : Vec < String > ,
304- ) -> IndexResult < JoinSet < IndexResult < ( Vec < CrateVersion > , Option < Publish > ) > > > {
305+ ) -> JoinSet < IndexResult < ( Vec < CrateVersion > , Option < Publish > ) > > {
305306 let mut join_set = JoinSet :: new ( ) ;
306307
307308 for index_key in index_keys {
@@ -317,7 +318,7 @@ fn get_latest_crate_publishes(
317318 } ) ;
318319 }
319320
320- Ok ( join_set)
321+ join_set
321322}
322323
323324fn convert_publish_to_crate_entry (
0 commit comments