result

Author: syphar

src/build_queue.rs

@@ -743,7 +743,7 @@ mod tests {
                 .max_queued_rebuilds(Some(100))
                 .build()?,
         )
-        .await;
+        .await?;
 
         env.fake_release()
             .await
@@ -777,7 +777,7 @@ mod tests {
                 .max_queued_rebuilds(Some(1))
                 .build()?,
         )
-        .await;
+        .await?;
 
         let build_queue = env.async_build_queue();
         build_queue
@@ -819,7 +819,7 @@ mod tests {
                 .max_queued_rebuilds(Some(1))
                 .build()?,
         )
-        .await;
+        .await?;
 
         let build_queue = env.async_build_queue();
         build_queue
@@ -852,7 +852,7 @@ mod tests {
 
     #[tokio::test(flavor = "multi_thread")]
     async fn test_add_duplicate_doesnt_fail_last_priority_wins() -> Result<()> {
-        let env = TestEnvironment::new().await;
+        let env = TestEnvironment::new().await?;
 
         let queue = env.async_build_queue();
 
@@ -870,7 +870,7 @@ mod tests {
     async fn test_add_duplicate_resets_attempts_and_priority() -> Result<()> {
         let env =
             TestEnvironment::with_config(TestEnvironment::base_config().build_attempts(5).build()?)
-                .await;
+                .await?;
 
         let queue = env.async_build_queue();
 
@@ -907,7 +907,7 @@ mod tests {
 
     #[tokio::test(flavor = "multi_thread")]
     async fn test_has_build_queued() -> Result<()> {
-        let env = TestEnvironment::new().await;
+        let env = TestEnvironment::new().await?;
 
         let queue = env.async_build_queue();
 
@@ -933,7 +933,7 @@ mod tests {
                 .build_attempts(99)
                 .delay_between_build_attempts(Duration::from_secs(1))
                 .build()?,
-        );
+        )?;
 
         let runtime = env.runtime();
 
@@ -984,7 +984,7 @@ mod tests {
                 .build_attempts(MAX_ATTEMPTS)
                 .delay_between_build_attempts(Duration::ZERO)
                 .build()?,
-        );
+        )?;
 
         let queue = env.build_queue();
 
@@ -1075,7 +1075,7 @@ mod tests {
                 .cloudfront_distribution_id_web(Some("distribution_id_web".into()))
                 .cloudfront_distribution_id_static(Some("distribution_id_static".into()))
                 .build()?,
-        );
+        )?;
 
         let queue = env.build_queue();
 
@@ -1125,7 +1125,7 @@ mod tests {
 
     #[test]
     fn test_pending_count() -> Result<()> {
-        let env = TestEnvironment::new_with_runtime();
+        let env = TestEnvironment::new_with_runtime()?;
 
         let queue = env.build_queue();
 
@@ -1148,7 +1148,7 @@ mod tests {
 
     #[test]
     fn test_prioritized_count() -> Result<()> {
-        let env = TestEnvironment::new_with_runtime();
+        let env = TestEnvironment::new_with_runtime()?;
 
         let queue = env.build_queue();
 
@@ -1171,7 +1171,7 @@ mod tests {
 
     #[test]
     fn test_count_by_priority() -> Result<()> {
-        let env = TestEnvironment::new_with_runtime();
+        let env = TestEnvironment::new_with_runtime()?;
 
         let queue = env.build_queue();
 
@@ -1201,7 +1201,7 @@ mod tests {
                 .build_attempts(MAX_ATTEMPTS)
                 .delay_between_build_attempts(Duration::ZERO)
                 .build()?,
-        );
+        )?;
 
         const MAX_ATTEMPTS: u16 = 3;
 
@@ -1240,7 +1240,7 @@ mod tests {
                 .build_attempts(MAX_ATTEMPTS)
                 .delay_between_build_attempts(Duration::ZERO)
                 .build()?,
-        );
+        )?;
 
         const MAX_ATTEMPTS: u16 = 3;
 
@@ -1271,7 +1271,7 @@ mod tests {
 
     #[test]
     fn test_queued_crates() -> Result<()> {
-        let env = TestEnvironment::new_with_runtime();
+        let env = TestEnvironment::new_with_runtime()?;
 
         let queue = env.build_queue();
 
@@ -1302,7 +1302,7 @@ mod tests {
 
     #[test]
     fn test_last_seen_reference_in_db() -> Result<()> {
-        let env = TestEnvironment::new_with_runtime();
+        let env = TestEnvironment::new_with_runtime()?;
 
         let queue = env.build_queue();
         queue.unlock()?;
@@ -1324,7 +1324,7 @@ mod tests {
 
     #[test]
     fn test_broken_db_reference_breaks() -> Result<()> {
-        let env = TestEnvironment::new_with_runtime();
+        let env = TestEnvironment::new_with_runtime()?;
 
         env.runtime().block_on(async {
             let mut conn = env.async_db().async_conn().await;
@@ -1341,7 +1341,7 @@ mod tests {
 
     #[test]
     fn test_queue_lock() -> Result<()> {
-        let env = TestEnvironment::new_with_runtime();
+        let env = TestEnvironment::new_with_runtime()?;
 
         let queue = env.build_queue();
         // unlocked without config
@@ -1358,7 +1358,7 @@ mod tests {
 
     #[test]
     fn test_add_long_name() -> Result<()> {
-        let env = TestEnvironment::new_with_runtime();
+        let env = TestEnvironment::new_with_runtime()?;
 
         let queue = env.build_queue();
 
@@ -1376,7 +1376,7 @@ mod tests {
 
     #[test]
     fn test_add_long_version() -> Result<()> {
-        let env = TestEnvironment::new_with_runtime();
+        let env = TestEnvironment::new_with_runtime()?;
 
         let queue = env.build_queue();
 

src/cdn.rs

@@ -708,7 +708,7 @@ mod tests {
                 .cdn_backend(CdnKind::CloudFront)
                 .build()?,
         )
-        .await;
+        .await?;
 
         assert!(matches!(*env.cdn(), CdnBackend::CloudFront { .. }));
         assert!(matches!(
@@ -719,19 +719,20 @@ mod tests {
     }
 
     #[tokio::test(flavor = "multi_thread")]
-    async fn create_dummy() {
-        let env = TestEnvironment::new().await;
+    async fn create_dummy() -> Result<()> {
+        let env = TestEnvironment::new().await?;
 
         assert!(matches!(*env.cdn(), CdnBackend::Dummy { .. }));
         assert!(matches!(
             CdnBackend::new(env.config()).await,
             CdnBackend::Dummy { .. }
         ));
+        Ok(())
     }
 
     #[tokio::test(flavor = "multi_thread")]
     async fn invalidation_counts_are_zero_with_empty_queue() -> Result<()> {
-        let env = TestEnvironment::with_config(config_with_cdn().build()?).await;
+        let env = TestEnvironment::with_config(config_with_cdn().build()?).await?;
 
         let config = env.config();
         let mut conn = env.async_db().async_conn().await;
@@ -757,7 +758,7 @@ mod tests {
                 .cdn_max_queued_age(Duration::from_secs(0))
                 .build()?,
         )
-        .await;
+        .await?;
 
         let cdn = env.cdn();
         let config = env.config();
@@ -859,7 +860,7 @@ mod tests {
 
     #[tokio::test(flavor = "multi_thread")]
     async fn invalidate_a_crate() -> Result<()> {
-        let env = TestEnvironment::with_config(config_with_cdn().build()?).await;
+        let env = TestEnvironment::with_config(config_with_cdn().build()?).await?;
 
         let cdn = env.cdn();
         let config = env.config();
@@ -990,7 +991,7 @@ mod tests {
 
     #[tokio::test(flavor = "multi_thread")]
     async fn only_add_some_invalidations_when_too_many_are_active() -> Result<()> {
-        let env = TestEnvironment::with_config(config_with_cdn().build()?).await;
+        let env = TestEnvironment::with_config(config_with_cdn().build()?).await?;
 
         let cdn = env.cdn();
 
@@ -1064,7 +1065,7 @@ mod tests {
 
     #[tokio::test(flavor = "multi_thread")]
     async fn dont_create_invalidations_when_too_many_are_active() -> Result<()> {
-        let env = TestEnvironment::with_config(config_with_cdn().build()?).await;
+        let env = TestEnvironment::with_config(config_with_cdn().build()?).await?;
 
         let cdn = env.cdn();
 
@@ -1153,7 +1154,7 @@ mod tests {
 
     #[tokio::test(flavor = "multi_thread")]
     async fn dont_create_invalidations_without_paths() -> Result<()> {
-        let env = TestEnvironment::with_config(config_with_cdn().build()?).await;
+        let env = TestEnvironment::with_config(config_with_cdn().build()?).await?;
 
         let cdn = env.cdn();
 

src/docbuilder/limits.rs

@@ -160,7 +160,7 @@ mod test {
                 .build_default_memory_limit(Some(6 * GB))
                 .build()?,
         )
-        .await;
+        .await?;
 
         let db = env.async_db();
         let mut conn = db.async_conn().await;