def _run_mpi_cmd(self, cmd):
        """
        This runs the command you send in
        """
        log("Number of Processes: {0}".format(self.num_processors))
        time_start = datetime.utcnow()

        # Construct the taudem command line.
        cmd = [self.mpiexec_path, '-n', str(self.num_processors)] + cmd
        log("Command Line: {0}".format(" ".join(cmd)))
        process = Popen(cmd, stdout=PIPE, stderr=PIPE, shell=False)
        out, err = process.communicate()
        if out:
            log("OUTPUT:")
            for line in out.split(b'\n'):
                log(line)
        if err:
            log(err, severity="WARNING")
        log("Time to complete: {0}".format(datetime.utcnow()-time_start))
def _run_mpi_cmd ( self , cmd ) : log ( "Number of Processes: {0}" . format ( self . num_processors ) ) time_start = datetime . utcnow ( ) cmd = [ self . mpiexec_path , '-n' , str ( self . num_processors ) ] + cmd log ( "Command Line: {0}" . format ( " " . join ( cmd ) ) ) process = Popen ( cmd , stdout = PIPE , stderr = PIPE , shell = False ) out , err = process . communicate ( ) if out : log ( "OUTPUT:" ) for line in out . split ( b'\n' ) : log ( line ) if err : log ( err , severity = "WARNING" ) log ( "Time to complete: {0}" . format ( datetime . utcnow ( ) - time_start ) )
This runs the command you send in