cover both zero and non-zero linger in test

Author: quettabit

tests/test_batching.py

@@ -85,7 +85,12 @@ async def delayed_records():
 
 
 @pytest.mark.asyncio
-async def test_batch_accumulator_flushes_when_source_iter_raises():
+@pytest.mark.parametrize(
+    "linger",
+    [timedelta(0), timedelta(milliseconds=10)],
+    ids=["no_linger", "linger"],
+)
+async def test_batch_accumulator_flushes_when_source_iter_raises(linger):
     async def records():
         yield Record(body=b"r1")
         yield Record(body=b"r2")
@@ -94,7 +99,7 @@ async def records():
     batches = []
     with pytest.raises(RuntimeError, match="err"):
         async for batch in append_record_batches(
-            records(), batching=Batching(linger=timedelta(0))
+            records(), batching=Batching(linger=linger)
         ):
             batches.append(batch)