1- use crate :: db:: { delete_crate, delete_version, update_latest_version_id, CrateId , Pool } ;
1+ use crate :: Context ;
2+ use crate :: db:: { CrateId , Pool , delete_crate, delete_version, update_latest_version_id} ;
23use crate :: docbuilder:: PackageKind ;
34use crate :: error:: Result ;
45use crate :: storage:: AsyncStorage ;
5- use crate :: utils:: { get_config, get_crate_priority, report_error, retry, set_config, ConfigName } ;
6- use crate :: Context ;
7- use crate :: { cdn, BuildPackageSummary } ;
6+ use crate :: utils:: { ConfigName , get_config, get_crate_priority, report_error, retry, set_config} ;
7+ use crate :: { BuildPackageSummary , cdn} ;
88use crate :: { Config , Index , InstanceMetrics , RustwideBuilder } ;
99use anyhow:: Context as _;
1010use fn_error_context:: context;
11- use futures_util:: { stream:: TryStreamExt , StreamExt } ;
11+ use futures_util:: { StreamExt , stream:: TryStreamExt } ;
1212use sqlx:: Connection as _;
1313use std:: collections:: HashMap ;
1414use std:: sync:: Arc ;
@@ -125,7 +125,7 @@ impl AsyncBuildQueue {
125125 . pending_count_by_priority ( )
126126 . await ?
127127 . iter ( )
128- . filter ( |( & priority, _) | priority <= 0 )
128+ . filter ( |& ( & priority, _) | priority <= 0 )
129129 . map ( |( _, count) | count)
130130 . sum :: < usize > ( ) )
131131 }
@@ -756,8 +756,10 @@ mod tests {
756756 . await
757757 . name ( "foo" )
758758 . version ( "0.1.0" )
759- . builds ( vec ! [ FakeBuild :: default ( )
760- . rustc_version( "rustc 1.84.0-nightly (e7c0d2750 2020-10-15)" ) ] )
759+ . builds ( vec ! [
760+ FakeBuild :: default ( )
761+ . rustc_version( "rustc 1.84.0-nightly (e7c0d2750 2020-10-15)" ) ,
762+ ] )
761763 . create ( )
762764 . await ?;
763765
@@ -785,8 +787,10 @@ mod tests {
785787 . await
786788 . name ( "foo" )
787789 . version ( "0.1.0" )
788- . builds ( vec ! [ FakeBuild :: default ( )
789- . rustc_version( "rustc 1.84.0-nightly (e7c0d2750 2020-10-15)" ) ] )
790+ . builds ( vec ! [
791+ FakeBuild :: default ( )
792+ . rustc_version( "rustc 1.84.0-nightly (e7c0d2750 2020-10-15)" ) ,
793+ ] )
790794 . create ( )
791795 . await ?;
792796
@@ -833,8 +837,10 @@ mod tests {
833837 . await
834838 . name ( "foo" )
835839 . version ( "0.1.0" )
836- . builds ( vec ! [ FakeBuild :: default ( )
837- . rustc_version( "rustc 1.84.0-nightly (e7c0d2750 2020-10-15)" ) ] )
840+ . builds ( vec ! [
841+ FakeBuild :: default ( )
842+ . rustc_version( "rustc 1.84.0-nightly (e7c0d2750 2020-10-15)" ) ,
843+ ] )
838844 . create ( )
839845 . await ?;
840846
@@ -867,8 +873,10 @@ mod tests {
867873 . await
868874 . name ( "foo" )
869875 . version ( "0.1.0" )
870- . builds ( vec ! [ FakeBuild :: default ( )
871- . rustc_version( "rustc 1.84.0-nightly (e7c0d2750 2020-10-15)" ) ] )
876+ . builds ( vec ! [
877+ FakeBuild :: default ( )
878+ . rustc_version( "rustc 1.84.0-nightly (e7c0d2750 2020-10-15)" ) ,
879+ ] )
872880 . create ( )
873881 . await ?;
874882
@@ -1090,15 +1098,16 @@ mod tests {
10901098 assert_eq ! ( metrics. build_time. get_sample_count( ) , 9 ) ;
10911099
10921100 // no invalidations were run since we don't have a distribution id configured
1093- assert ! ( env
1094- . runtime( )
1095- . block_on( async {
1096- cdn:: queued_or_active_crate_invalidations(
1097- & mut * env. async_db( ) . await . async_conn( ) . await ,
1098- )
1099- . await
1100- } ) ?
1101- . is_empty( ) ) ;
1101+ assert ! (
1102+ env. runtime( )
1103+ . block_on( async {
1104+ cdn:: queued_or_active_crate_invalidations(
1105+ & mut * env. async_db( ) . await . async_conn( ) . await ,
1106+ )
1107+ . await
1108+ } ) ?
1109+ . is_empty( )
1110+ ) ;
11021111
11031112 Ok ( ( ) )
11041113 } )
@@ -1135,9 +1144,11 @@ mod tests {
11351144
11361145 let queued_invalidations = fetch_invalidations ( ) ;
11371146 assert_eq ! ( queued_invalidations. len( ) , 3 ) ;
1138- assert ! ( queued_invalidations
1139- . iter( )
1140- . all( |i| i. krate == "will_succeed" ) ) ;
1147+ assert ! (
1148+ queued_invalidations
1149+ . iter( )
1150+ . all( |i| i. krate == "will_succeed" )
1151+ ) ;
11411152
11421153 queue. process_next_crate ( |krate| {
11431154 assert_eq ! ( "will_fail" , krate. name) ;
@@ -1146,10 +1157,12 @@ mod tests {
11461157
11471158 let queued_invalidations = fetch_invalidations ( ) ;
11481159 assert_eq ! ( queued_invalidations. len( ) , 6 ) ;
1149- assert ! ( queued_invalidations
1150- . iter( )
1151- . skip( 3 )
1152- . all( |i| i. krate == "will_fail" ) ) ;
1160+ assert ! (
1161+ queued_invalidations
1162+ . iter( )
1163+ . skip( 3 )
1164+ . all( |i| i. krate == "will_fail" )
1165+ ) ;
11531166
11541167 Ok ( ( ) )
11551168 } )
0 commit comments