don't parallelize upsample (#3836)

pola-rs · Jun 28, 2022 · a15b6b1 · a15b6b1
1 parent 1f6369b
commit a15b6b1
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/polars/polars-time/src/upsample.rs b/polars/polars-time/src/upsample.rs
@@ -119,7 +119,11 @@ fn upsample_impl(
         } else {
             source.groupby(by)
         };
-        gb?.par_apply(|df| upsample_impl(&df, vec![], index_column, every, offset, false))
+        // don't parallelize this, this may SO on large data.
+        gb?.apply(|df| {
+            let index_column = df.column(index_column)?;
+            upsample_single_impl(&df, index_column, every, offset)
+        })
     }
 }