def METHOD_NAME():
    path = file_relative_path(__file__, "canada.csv")
    npartitions = 2
    input_df = dd.read_csv(path)
    assert input_df.npartitions == 1
    # Repartition from 1 to 2 partitions.
    run_config = generate_config(path, repartition={"npartitions": npartitions})
    result = wrap_op_in_graph_and_execute(
        passthrough, run_config=run_config, do_input_mapping=False
    )
    output_df = result.output_value()
    assert output_df.npartitions == npartitions