def _orted_process()

in src/sagemaker_training/mpi.py [0:0]

• 7 lines of code
• 5 McCabe index (conditional complexity)

def _orted_process():  # pylint: disable=inconsistent-return-statements
    """Wait a maximum of 20 minutes for orted process to start."""
    # the wait time here should be set to a dynamic value according to cluster size
    for _ in range(20 * 60):
        procs = [p for p in psutil.process_iter(attrs=["name"]) if p.info["name"] == "orted"]
        if procs:
            logger.info("Process[es]: %s", procs)
            return procs
        time.sleep(1)