Function new_group

checkpoint_engine/distributed/base.py:287–288

(ranks: list[int], **kwargs)

def new_group(ranks: list[int], **kwargs) -> DistributedProcessGroup | None:
    return _BACKEND_INSTANCE.new_group(ranks, **kwargs)