The WorkerRunner proceeds as following:

        - wait for the MPI Master to create its SSH daemon
        - start its SSH daemon
        - monitor the MPI orted process and wait it to finish the MPI execution

def run(self, wait=True, capture_error=False):  # type: (bool, bool) -> None
        """The WorkerRunner proceeds as following:

        - wait for the MPI Master to create its SSH daemon
        - start its SSH daemon
        - monitor the MPI orted process and wait it to finish the MPI execution
        """
        logger.info('Starting MPI run as worker node.')
        if wait:
            logger.info('Waiting for MPI Master to create SSH daemon.')
            self._wait_master_to_start()
        logger.info('MPI Master online, creating SSH daemon.')

        _start_sshd_daemon()

        if wait:
            logger.info('Waiting for MPI process to finish.')
            _wait_orted_process_to_finish()
            time.sleep(30)
        logger.info('MPI process finished.')