From f0ddc2c2b5a9b73a1c37ca593dc72fc7c2e296dd Mon Sep 17 00:00:00 2001 From: Sammy Sidhu Date: Thu, 12 Oct 2023 22:06:44 -0700 Subject: [PATCH] disable for windows --- daft/series.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/daft/series.py b/daft/series.py index 12506b28f..ece133c06 100644 --- a/daft/series.py +++ b/daft/series.py @@ -1,5 +1,6 @@ from __future__ import annotations +import sys from typing import TypeVar import pyarrow as pa @@ -490,7 +491,11 @@ def image(self) -> SeriesImageNamespace: def __reduce__(self) -> tuple: if self.datatype()._is_python_type(): return (Series.from_pylist, (self.to_pylist(), self.name(), "force")) + elif sys.platform == "win32": + return (Series.from_arrow, (self.to_arrow(), self.name())) else: + # Ray Special CloudPickling fast path. + # Only run for Linux and Mac, since windows runs slower for some reason return ( Series._from_arrow_table_to_series, self._to_arrow_table_for_serdes(),