(meta, actual)
| 389 | |
| 390 | |
| 391 | def check_matching_columns(meta, actual): |
| 392 | import dask.dataframe.methods as methods |
| 393 | |
| 394 | # Need nan_to_num otherwise nan comparison gives False |
| 395 | if not np.array_equal(np.nan_to_num(meta.columns), np.nan_to_num(actual.columns)): |
| 396 | extra = methods.tolist(actual.columns.difference(meta.columns)) |
| 397 | missing = methods.tolist(meta.columns.difference(actual.columns)) |
| 398 | if extra or missing: |
| 399 | extra_info = f" Extra: {extra}\n Missing: {missing}" |
| 400 | else: |
| 401 | extra_info = ( |
| 402 | f"Order of columns does not match." |
| 403 | f"\nActual: {actual.columns.tolist()}" |
| 404 | f"\nExpected: {meta.columns.tolist()}" |
| 405 | ) |
| 406 | raise ValueError( |
| 407 | "The columns in the computed data do not match" |
| 408 | " the columns in the provided metadata.\n" |
| 409 | f"{extra_info}" |
| 410 | ) |
| 411 | |
| 412 | |
| 413 | def index_summary(idx, name=None): |
no outgoing calls