Skip to content

Commit d3d6ff1

Browse files
authored
Register default backends when restoring state (#1550)
Signed-off-by: Alex Kment <[email protected]>
1 parent cdf9ffc commit d3d6ff1

File tree

3 files changed

+8
-2
lines changed

3 files changed

+8
-2
lines changed

pandera/api/base/schema.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -132,6 +132,10 @@ def _register_default_backends(self):
132132
overridden in those subclasses.
133133
"""
134134

135+
def __setstate__(self, state):
136+
self.__dict__ = state
137+
self._register_default_backends()
138+
135139

136140
def inferred_schema_guard(method):
137141
"""

tests/core/test_pandas_parallel.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,10 +4,11 @@
44
from joblib import Parallel, delayed
55
from pandera import Column, DataFrameSchema
66

7+
schema = DataFrameSchema({"a": Column("int64")}, coerce=True)
8+
79

810
def test_polars_parallel():
911
def fn():
10-
schema = DataFrameSchema({"a": Column("int64")}, coerce=True)
1112
return schema.validate(pd.DataFrame({"a": [1]}))
1213

1314
results = Parallel(2)([delayed(fn)() for _ in range(10)])

tests/polars/test_polars_parallel.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,10 +4,11 @@
44
from joblib import Parallel, delayed
55
from pandera.polars import Column, DataFrameSchema
66

7+
schema = DataFrameSchema({"a": Column(pl.Int32)}, coerce=True)
8+
79

810
def test_polars_parallel():
911
def fn():
10-
schema = DataFrameSchema({"a": Column(pl.Int32)}, coerce=True)
1112
return schema.validate(pl.DataFrame({"a": [1]}))
1213

1314
results = Parallel(2)([delayed(fn)() for _ in range(10)])

0 commit comments

Comments
 (0)