Skip to content

Commit

Permalink
longer test
Browse files Browse the repository at this point in the history
  • Loading branch information
ebonnal committed Sep 30, 2024
1 parent 597a842 commit 21838bd
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions tests/test_stream.py
Original file line number Diff line number Diff line change
Expand Up @@ -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),
Expand All @@ -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)
)
Expand All @@ -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(
Expand Down

0 comments on commit 21838bd

Please sign in to comment.