Widen redelivery timeouts in tests for Windows timer resolution

The redelivery counter test used 50ms timeout with 75ms sleep (25ms margin),
and the abandoned worker test used 100ms/125ms. Windows ~15ms timer resolution
makes these too tight, causing worker crashes in CI. Widened both to 200ms/250ms.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: chrisguidry

tests/instrumentation/test_counters.py

@@ -343,7 +343,7 @@ async def test_task():
 
     await docket.add(test_task)()
 
-    worker = Worker(docket, redelivery_timeout=timedelta(milliseconds=50))
+    worker = Worker(docket, redelivery_timeout=timedelta(milliseconds=200))
 
     async with worker:
         worker._execute = AsyncMock(side_effect=Exception("Simulated worker failure"))  # type: ignore[assignment]
@@ -354,9 +354,9 @@ async def test_task():
             "Simulated worker failure" in str(e) for e in exc_info.value.exceptions
         )
 
-    await asyncio.sleep(0.075)
+    await asyncio.sleep(0.25)
 
-    worker2 = Worker(docket, redelivery_timeout=timedelta(milliseconds=100))
+    worker2 = Worker(docket, redelivery_timeout=timedelta(milliseconds=200))
     async with worker2:
         await worker2.run_until_finished()
 

tests/test_redelivery.py

@@ -36,7 +36,7 @@ async def test_redelivery_from_abandoned_worker(docket: Docket, the_task: AsyncM
     await docket.add(the_task)()
 
     async with Worker(
-        docket, redelivery_timeout=timedelta(milliseconds=100)
+        docket, redelivery_timeout=timedelta(milliseconds=200)
     ) as worker_a:
         worker_a._execute = AsyncMock(side_effect=Exception("Nope"))  # pyright: ignore[reportPrivateUsage]
         with pytest.raises(ExceptionGroup) as exc_info:
@@ -46,7 +46,7 @@ async def test_redelivery_from_abandoned_worker(docket: Docket, the_task: AsyncM
     the_task.assert_not_called()
 
     async with Worker(
-        docket, redelivery_timeout=timedelta(milliseconds=100)
+        docket, redelivery_timeout=timedelta(milliseconds=200)
     ) as worker_b:
         async with docket.redis() as redis:
             pending_info = await redis.xpending(
@@ -57,7 +57,7 @@ async def test_redelivery_from_abandoned_worker(docket: Docket, the_task: AsyncM
                 "Expected one pending task in the stream"
             )
 
-        await asyncio.sleep(0.125)  # longer than the redelivery timeout
+        await asyncio.sleep(0.25)  # longer than the redelivery timeout
 
         await worker_b.run_until_finished()