(batch: pd.DataFrame)
| 229 | if is_ray_data(data): |
| 230 | |
| 231 | def normalize_batch(batch: pd.DataFrame) -> pd.DataFrame: |
| 232 | for column in column_list: |
| 233 | if ( |
| 234 | not batch.empty |
| 235 | and column in batch.columns |
| 236 | and column not in exclude_columns |
| 237 | ): |
| 238 | batch[column] = apply_normalization(batch[column]) |
| 239 | return batch |
| 240 | |
| 241 | return data.map_batches(normalize_batch, batch_format="pandas") |
| 242 | else: |
nothing calls this directly
no test coverage detected