src/sk_utils.py [124:133]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    if os.environ['SIGNAL_RECEIVED'] == 'True':
        if args.rank == 0:
            logger.info("Beginning requeue", logger=logger)
            trigger_job_requeue(os.path.join(
                args.dump_path, "checkpoint.pth.tar"))
    # Ensure processes reach to end of optim clusters
    if group is not None:
        dist.barrier(group=group)
    else:
        dist.barrier()
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/sk_utils.py [245:254]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            if os.environ['SIGNAL_RECEIVED'] == 'True':
                if args.rank == 0:
                    logger.info("Beginning requeue", logger=logger)
                    trigger_job_requeue(os.path.join(
                        args.dump_path, "checkpoint.pth.tar"))

            if group is not None:
                dist.barrier(group=group)
            else:
                dist.barrier()
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -