Adjust threshold of limiter test (#341)

Author: qianl15

tests/test_queue.py

@@ -233,12 +233,12 @@ def test_workflow(var1: str, var2: str) -> float:
     # Verify that each "wave" of tasks started at the ~same time.
     for wave in range(num_waves):
         for i in range(wave * limit, (wave + 1) * limit - 1):
-            assert times[i + 1] - times[i] < 0.2
+            assert times[i + 1] - times[i] < 0.3
 
     # Verify that the gap between "waves" is ~equal to the period
     for wave in range(num_waves - 1):
-        assert times[limit * (wave + 1)] - times[limit * wave] > period - 0.2
-        assert times[limit * (wave + 1)] - times[limit * wave] < period + 0.2
+        assert times[limit * (wave + 1)] - times[limit * wave] > period - 0.3
+        assert times[limit * (wave + 1)] - times[limit * wave] < period + 0.3
 
     # Verify all workflows get the SUCCESS status eventually
     for h in handles:
@@ -300,12 +300,12 @@ def limited_workflow(var1: str, var2: str) -> float:
     # Verify that each "wave" of tasks started at the ~same time.
     for wave in range(num_waves):
         for i in range(wave * limit, (wave + 1) * limit - 1):
-            assert times[i + 1] - times[i] < 0.2
+            assert times[i + 1] - times[i] < 0.3
 
     # Verify that the gap between "waves" is ~equal to the period
     for wave in range(num_waves - 1):
-        assert times[limit * (wave + 1)] - times[limit * wave] > period - 0.2
-        assert times[limit * (wave + 1)] - times[limit * wave] < period + 0.2
+        assert times[limit * (wave + 1)] - times[limit * wave] > period - 0.3
+        assert times[limit * (wave + 1)] - times[limit * wave] < period + 0.3
 
     # Verify all workflows get the SUCCESS status eventually
     for h in handles: