def METHOD_NAME():
    from mpi4py import MPI as MPI4PY
    comm = MPI4PY.COMM_WORLD
    rank = comm.Get_rank()
    commsize = comm.Get_size()
    mpi_sdfg = None
    if commsize < 2:
        raise ValueError("This test is supposed to be run with at least two processes!")
    sdfg = None
    if rank == 0:
        sdfg = dace_send_recv.to_sdfg(simplify=True)
        # Disable OpenMP section to allow blocking
        sdfg.openmp_sections = False
    mpi_sdfg = utils.distributed_compile(sdfg, comm)
    val = mpi_sdfg(rank=rank, size=commsize)
    assert (val[0] == (rank - 1) % commsize)