Function get_default_shuffle_method

dask/utils.py:2222–2237

()

def get_default_shuffle_method() -> str:
    if d := config.get("dataframe.shuffle.method", None):
        return d
    try:
        from distributed import default_client

        default_client()
    except (ImportError, ValueError):
        return "disk"

    try:
        from dask.dataframe._compat import HAS_PYARROW

        return "p2p" if HAS_PYARROW else "tasks"
    except ImportError:
        return "tasks"


def get_meta_library(like):