Method barrier

checkpoint_engine/distributed/base.py:85–90

(
        self,
        group: DistributedProcessGroup | None = None,
        **kwargs,
    )

    @abstractmethod
    def barrier(
        self,
        group: DistributedProcessGroup | None = None,
        **kwargs,
    ):
        raise NotImplementedError

    @abstractmethod
    def new_group(