cleaning

Author: sanderegg

packages/service-library/tests/redis/test_semaphore_decorator.py

@@ -350,7 +350,7 @@ async def function_raising_cancelled_error():
         await function_raising_cancelled_error()
 
 
-@pytest.mark.skip
+# @pytest.mark.skip
 async def test_with_large_capacity(
     redis_client_sdk: RedisClientSDK,
     semaphore_name: str,
@@ -368,7 +368,7 @@ async def test_with_large_capacity(
         blocking=True,
         blocking_timeout=None,
     )
-    async def limited_function():
+    async def limited_function() -> None:
         nonlocal concurrent_count, max_concurrent
         concurrent_count += 1
         max_concurrent = max(max_concurrent, concurrent_count)
@@ -377,7 +377,7 @@ async def limited_function():
 
     # Start tasks equal to the large capacity
     tasks = [asyncio.create_task(limited_function()) for _ in range(num_tasks)]
-    async with asyncio.timeout(num_tasks / large_capacity * 2 * sleep_time_s):
+    async with asyncio.timeout(num_tasks / large_capacity * 5 * sleep_time_s):
         await asyncio.gather(*tasks)
 
     # Should never exceed the large capacity