def barrier()

in torchrecipes/utils/distributed_utils.py [0:0]

• 4 lines of code
• 3 McCabe index (conditional complexity)

def barrier() -> None:
    """
    Wrapper over torch.distributed.barrier, returns without waiting
    if the distributed process group is not initialized instead of throwing error.
    """
    if not torch.distributed.is_available() or not torch.distributed.is_initialized():
        return
    torch.distributed.barrier()