From df1ec3513f5191940f0ecc784439a3bc3c808b55 Mon Sep 17 00:00:00 2001 From: Filipp Shpomer Date: Wed, 20 May 2026 11:05:36 -0700 Subject: [PATCH] fix: replace applymap() removed in pandas 3.0 --- cdisc_rules_engine/services/data_readers/dataset_json_reader.py | 2 +- .../services/data_readers/dataset_ndjson_reader.py | 2 +- cdisc_rules_engine/services/data_readers/parquet_reader.py | 2 +- cdisc_rules_engine/services/data_readers/xpt_reader.py | 2 +- cdisc_rules_engine/services/data_services/dummy_data_service.py | 2 +- 5 files changed, 5 insertions(+), 5 deletions(-) diff --git a/cdisc_rules_engine/services/data_readers/dataset_json_reader.py b/cdisc_rules_engine/services/data_readers/dataset_json_reader.py index 71e312528..d95824a3c 100644 --- a/cdisc_rules_engine/services/data_readers/dataset_json_reader.py +++ b/cdisc_rules_engine/services/data_readers/dataset_json_reader.py @@ -36,7 +36,7 @@ def _raw_dataset_from_file(self, file_path) -> pd.DataFrame: [item for item in datasetjson.get("rows", [])], columns=[item["name"] for item in datasetjson.get("columns", [])], ) - return df.applymap(lambda x: round(x, 15) if isinstance(x, float) else x) + return df.map(lambda x: round(x, 15) if isinstance(x, float) else x) def from_file(self, file_path): try: diff --git a/cdisc_rules_engine/services/data_readers/dataset_ndjson_reader.py b/cdisc_rules_engine/services/data_readers/dataset_ndjson_reader.py index 48b998e40..c2652343e 100644 --- a/cdisc_rules_engine/services/data_readers/dataset_ndjson_reader.py +++ b/cdisc_rules_engine/services/data_readers/dataset_ndjson_reader.py @@ -45,7 +45,7 @@ def _raw_dataset_from_file(self, file_path) -> pd.DataFrame: [item for item in datandjson], columns=[item["name"] for item in metadatandjson.get("columns", [])], ) - return df.applymap(lambda x: round(x, 15) if isinstance(x, float) else x) + return df.map(lambda x: round(x, 15) if isinstance(x, float) else x) def from_file(self, file_path): try: diff --git a/cdisc_rules_engine/services/data_readers/parquet_reader.py b/cdisc_rules_engine/services/data_readers/parquet_reader.py index 6e7867b63..1df298969 100644 --- a/cdisc_rules_engine/services/data_readers/parquet_reader.py +++ b/cdisc_rules_engine/services/data_readers/parquet_reader.py @@ -32,7 +32,7 @@ def from_file(self, file_path): def _format_floats( self, dataframe: Union[pd.DataFrame, dd.DataFrame] ) -> Union[pd.DataFrame, dd.DataFrame]: - return dataframe.applymap(lambda x: round(x, 15) if isinstance(x, float) else x) + return dataframe.map(lambda x: round(x, 15) if isinstance(x, float) else x) def _read_dask(self, file_path): data = dd.read_parquet(file_path) diff --git a/cdisc_rules_engine/services/data_readers/xpt_reader.py b/cdisc_rules_engine/services/data_readers/xpt_reader.py index d20e1e85d..f2068bedc 100644 --- a/cdisc_rules_engine/services/data_readers/xpt_reader.py +++ b/cdisc_rules_engine/services/data_readers/xpt_reader.py @@ -50,4 +50,4 @@ def from_file(self, file_path): return self._read_pandas(file_path) def _format_floats(self, dataframe: pd.DataFrame) -> pd.DataFrame: - return dataframe.applymap(lambda x: round(x, 15) if isinstance(x, float) else x) + return dataframe.map(lambda x: round(x, 15) if isinstance(x, float) else x) diff --git a/cdisc_rules_engine/services/data_services/dummy_data_service.py b/cdisc_rules_engine/services/data_services/dummy_data_service.py index b2caa3796..92f4b958d 100644 --- a/cdisc_rules_engine/services/data_services/dummy_data_service.py +++ b/cdisc_rules_engine/services/data_services/dummy_data_service.py @@ -62,7 +62,7 @@ def get_dataset(self, dataset_name: str, **params) -> PandasDataset: dataset: Optional[DummyDataset] = self.get_dataset_data(dataset_name) if dataset is not None: df: pd.DataFrame = dataset.data - df = df.applymap(lambda x: x.decode("utf-8") if isinstance(x, bytes) else x) + df = df.map(lambda x: x.decode("utf-8") if isinstance(x, bytes) else x) result = PandasDataset(df) return result else: