code: def run(self, wait=True, capture_error=False):  # type: (bool, bool) -> None
          
          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.')
docs: 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