@@ -319,7 +319,7 @@ def __setattr__(self, name, value):
319319
320320
321321
322- def ExecuteCMD (self , cmd , raise_error = True , return_output = False , on_cluster = False ):
322+ def ExecuteCMD (self , cmd , raise_error = False , return_output = False , on_cluster = False ):
323323 """
324324 EXECUTE THE CMD ON THE CLUSTER
325325 ==============================
@@ -797,7 +797,7 @@ def submit(self, script_location):
797797 #cmd = self.sshcmd + " %s '%s %s/%s.sh'" % (self.hostname, self.submit_command,
798798 # self.workdir, label+ "_" + str(indices[0]))
799799
800- return self .ExecuteCMD (cmd , True , return_output = True )
800+ return self .ExecuteCMD (cmd , False , return_output = True )
801801
802802 def get_output_path (self , label ):
803803 """
@@ -1375,7 +1375,7 @@ def setup_workdir(self, verbose = True):
13751375 sshcmd = self .sshcmd + " %s 'mkdir -p %s'" % (self .hostname ,
13761376 workdir )
13771377
1378- self .ExecuteCMD (sshcmd )
1378+ self .ExecuteCMD (sshcmd , raise_error = True )
13791379#
13801380# retval = os.system(sshcmd)
13811381# if retval != 0:
@@ -1423,7 +1423,7 @@ def parse_string(self, string):
14231423
14241424 #print(cmd)
14251425
1426- status , output = self .ExecuteCMD (cmd , return_output = True )
1426+ status , output = self .ExecuteCMD (cmd , return_output = True , raise_error = True )
14271427#
14281428# p = subprocess.Popen(cmd, stdout=subprocess.PIPE, shell=True)
14291429# output, err = p.communicate()
0 commit comments