def METHOD_NAME():
    run_config = {
        "ops": {
            "dask_op": {
                "inputs": {
                    "df": {"read": {"csv": {"path": file_relative_path(__file__, "ex*.csv")}}}
                }
            }
        }
    }
    with instance_for_test() as instance:
        with execute_job(
            reconstructable(dask_job),
            run_config={
                "execution": {"config": {"cluster": {"local": {"timeout": 30}}}},
                **run_config,
            },
            instance=instance,
        ) as result:
            assert result.success