def get_data_parallel_world_size():
    """Return world size for the data parallel group."""
    return get_world_size(get_data_parallel_group())
Return world size for the data parallel group.
fairseq/distributed/utils.py