Function assert_sane_keynames

dask/dataframe/utils.py:614–624

(ddf)

def assert_sane_keynames(ddf):
    if hasattr(ddf, "__dask_graph__"):
        dsk = ddf.optimize()
        dsk = dsk.__dask_graph__()
        for k in dsk:
            while isinstance(k, tuple):
                k = k[0]
            assert isinstance(k, (str, bytes))
            assert len(k) < 100
            assert " " not in k
            assert k.split("-")[0].isidentifier(), k


def assert_dask_dtypes(ddf, res, numeric_equal=True):