fixup! fixup! fixup! Feat: stream completed chunks

Author: vincevannoort

libs/opsqueue_python/tests/test_roundtrip.py

@@ -682,13 +682,13 @@ def test_streams_completed_chunks_before_submission_finishes(
     )
 
     def complete_chunks(
-        _submission_id_value: int, 
+        _submission_id_value: int,
         strategy: StrategyDescription,
     ) -> None:
         consumer_client = ConsumerClient(f"localhost:{opsqueue.port}", url)
         chunks = sorted(
             consumer_client.reserve_chunks(
-                max=2, 
+                max=2,
                 strategy=strategy_from_description(strategy),
             ),
             key=lambda chunk: chunk.chunk_index,
@@ -727,13 +727,13 @@ def test_async_streams_completed_chunks_before_submission_finishes(
     )
 
     def complete_chunks(
-        _submission_id_value: int, 
+        _submission_id_value: int,
         strategy: StrategyDescription,
     ) -> None:
         consumer_client = ConsumerClient(f"localhost:{opsqueue.port}", url)
         chunks = sorted(
             consumer_client.reserve_chunks(
-                max=2, 
+                max=2,
                 strategy=strategy_from_description(strategy),
             ),
             key=lambda chunk: chunk.chunk_index,