Skip to content

Commit 9375bf6

Browse files
authored
updated to_dict dask (#1280)
1 parent ee11356 commit 9375bf6

4 files changed

Lines changed: 1 addition & 1 deletion

File tree

cdisc_rules_engine/models/dataset/dask_dataset.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -360,7 +360,7 @@ def fillna(
360360
return self.__class__(result)
361361

362362
def to_dict(self, **kwargs) -> dict:
363-
return list(self._data.map_partitions(lambda x: x.to_dict(orient="records")))
363+
return self._data.compute().to_dict(**kwargs)
364364

365365
def items(self, **kwargs):
366366
computed_df = self._data.compute()

resources/cache/rules.pkl

-1.82 KB
Binary file not shown.
-34 Bytes
Binary file not shown.
0 Bytes
Binary file not shown.

0 commit comments

Comments
 (0)