Function check_matching_columns

dask/dataframe/utils.py:388–407

(meta, actual)

def check_matching_columns(meta, actual):
    from dask.dataframe import methods

    # Need nan_to_num otherwise nan comparison gives False
    if not np.array_equal(np.nan_to_num(meta.columns), np.nan_to_num(actual.columns)):
        extra = methods.tolist(actual.columns.difference(meta.columns))
        missing = methods.tolist(meta.columns.difference(actual.columns))
        if extra or missing:
            extra_info = f"  Extra:   {extra}\n  Missing: {missing}"
        else:
            extra_info = (
                f"Order of columns does not match."
                f"\nActual:   {actual.columns.tolist()}"
                f"\nExpected: {meta.columns.tolist()}"
            )
        raise ValueError(
            "The columns in the computed data do not match"
            " the columns in the provided metadata.\n"
            f"{extra_info}"
        )


def index_summary(idx, name=None):