def METHOD_NAME(df, path, **kwargs):
    import dask.dataframe as dd
    if not is_dataframe_like(df):
        raise NotImplementedError
    try:
        from intake_parquet import ParquetSource
    except ImportError:
        raise ImportError("Please install intake-parquet to use persistence" " on dataframe container sources.")
    if not hasattr(df, "npartitions"):
        df = dd.from_pandas(df, npartitions=1)
    df.to_parquet(path, **kwargs)
    source = ParquetSource(path)
    return source