From b332b6d826c7c194efc11948528c56e7aa2e11c6 Mon Sep 17 00:00:00 2001
From: Imbolc <me@imbolc.name>
Date: Wed, 13 Jul 2022 16:59:27 +0300
Subject: [PATCH] Ci tests (#42)

* Increase pause during test runs in CI
---
 src/lib.rs | 19 +++++++++++++++----
 1 file changed, 15 insertions(+), 4 deletions(-)

diff --git a/src/lib.rs b/src/lib.rs
index 39b7f4f..1e79370 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -371,8 +371,20 @@ mod tests {
         registry.runner(pool).run().await.unwrap()
     }
 
+    fn is_ci() -> bool {
+        std::env::var("CI").ok().is_some()
+    }
+
+    fn default_pause() -> u64 {
+        if is_ci() {
+            1000
+        } else {
+            200
+        }
+    }
+
     async fn pause() {
-        pause_ms(200).await;
+        pause_ms(default_pause()).await;
     }
 
     async fn pause_ms(ms: u64) {
@@ -513,7 +525,7 @@ mod tests {
             let pool = &*test_pool().await;
             let (_runner, counter) = test_job_runner(pool, move |_| async {}).await;
 
-            let backoff = 500;
+            let backoff = default_pause() + 300;
 
             assert_eq!(counter.load(Ordering::SeqCst), 0);
             JobBuilder::new("foo")
@@ -561,7 +573,7 @@ mod tests {
             })
             .await;
 
-            let backoff = 200;
+            let backoff = default_pause();
 
             assert_eq!(counter.load(Ordering::SeqCst), 0);
             JobBuilder::new("foo")
@@ -579,7 +591,6 @@ mod tests {
 
             // Second attempt
             pause_ms(backoff).await;
-            pause().await;
             assert_eq!(counter.load(Ordering::SeqCst), 2);
 
             // No more attempts