Test: Nested PreferDistinct case

ReinierMaas · ReinierMaas · commit 788eacb84695 · 2026-07-10T15:24:56.000+02:00
diff --git a/libs/opsqueue_python/tests/conftest.py b/libs/opsqueue_python/tests/conftest.py
@@ -135,7 +135,13 @@ def multiple_background_processes(
 basic_strategies: Iterable[StrategyDescription] = ("Random", "Newest", "Oldest")
 any_strategies: Iterable[StrategyDescription] = (
     *(basic_strategies),
-    *(("PreferDistinct", "id", s) for s in basic_strategies),
+    *(
+        ("PreferDistinct", "id", s)
+        for s in (
+            *basic_strategies,
+            *(("PreferDistinct", "second_id", s) for s in basic_strategies),
+        )
+    ),
 )
 
 
diff --git a/libs/opsqueue_python/tests/test_roundtrip.py b/libs/opsqueue_python/tests/test_roundtrip.py
@@ -124,7 +124,9 @@ def run_consumer(_consumer_id: int) -> None:
         input_iter = range(0, n_ops)
 
         output_iter: Iterator[int] = producer_client.run_submission(
-            input_iter, chunk_size=chunk_size, strategic_metadata={"id": 42}
+            input_iter,
+            chunk_size=chunk_size,
+            strategic_metadata={"id": 42, "second_id": 69},
         )
         res = sum(output_iter)
 

Original file line number	Diff line number	Diff line change
`@@ -124,7 +124,9 @@ def run_consumer(_consumer_id: int) -> None:`
`124`	`124`	`input_iter = range(0, n_ops)`
`125`	`125`
`126`	`126`	`output_iter: Iterator[int] = producer_client.run_submission(`
`127`		`- input_iter, chunk_size=chunk_size, strategic_metadata={"id": 42}`
	`127`	`+ input_iter,`
	`128`	`+ chunk_size=chunk_size,`
	`129`	`+ strategic_metadata={"id": 42, "second_id": 69},`
`128`	`130`	`)`
`129`	`131`	`res = sum(output_iter)`
`130`	`132`