Function raise_exception

dask/dataframe/tests/test_dataframe.py:2427–2428

()

    @dask.delayed
    def raise_exception():
        raise RuntimeError()

    tasks = [raise_exception()]
    ddf = dd.from_delayed(tasks, meta=dict(a=float))