move scan into thread

pola-rs · Apr 2, 2024 · 21283b6 · 21283b6
1 parent 168cd52
commit 21283b6
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/py-polars/tests/unit/io/test_lazy_parquet.py b/py-polars/tests/unit/io/test_lazy_parquet.py
@@ -424,10 +424,8 @@ def test_scan_deadlock_rayon_nested_spawn_15172(
 
     results = [pl.DataFrame()]
 
-    lfs = [pl.scan_parquet(path)]
-
     def scan_collect() -> pl.DataFrame:
-        results[0] = pl.collect_all(lfs)[0]
+        results[0] = pl.collect_all([pl.scan_parquet(path)])[0]
 
     # Make sure we don't sit there hanging for hours on the broken case
     t = Thread(target=scan_collect, daemon=True)