diff --git a/tests/test_stream.py b/tests/test_stream.py index 606e1a3..e531832 100644 --- a/tests/test_stream.py +++ b/tests/test_stream.py @@ -372,8 +372,8 @@ def test_map_with_more_concurrency_than_elements( func, ] for ordered, order_mutation, expected_duration in [ - (True, identity, 0.3), - (False, sorted, 0.21), + (True, identity, 3), + (False, sorted, 2.1), ] for operation, func in [ (Stream.foreach, time.sleep), @@ -391,7 +391,7 @@ def test_mapping_ordering( operation, func, ): - seconds = [0.1, 0.01, 0.2] + seconds = [1, 0.1, 2] duration, res = timestream( operation(Stream(seconds), func, ordered=ordered, concurrency=2) ) @@ -405,7 +405,7 @@ def test_mapping_ordering( duration, expected_duration, msg=f"{'ordered' if ordered else 'unordered'} `{operation}` should reflect that unordering improves runtime by avoiding bottlenecks", - delta=0.04, + delta=0.01, ) @parameterized.expand(