fix: changed sge to use subprocess directly

Author: satra

nipype/pipeline/plugins/pbs.py

@@ -39,7 +39,7 @@ def _is_pending(self, taskid):
         proc = subprocess.Popen(["qstat", taskid],
                                 stdout=subprocess.PIPE,
                                 stderr=subprocess.PIPE)
-        o,e=proc.communicate()
+        _, e = proc.communicate()
         errmsg = 'Unknown Job Id' # %s' % taskid 
         return  errmsg not in e
 

nipype/pipeline/plugins/sge.py

@@ -2,12 +2,13 @@
 """
 
 import os
+import subprocess
+from time import sleep
 
 from .base import (SGELikeBatchManagerBase, logger, iflogger, logging)
 
 from nipype.interfaces.base import CommandLine
 
-from time import sleep
 
 class SGEPlugin(SGELikeBatchManagerBase):
     """Execute using SGE (OGE not tested)
@@ -36,16 +37,11 @@ def __init__(self, **kwargs):
         super(SGEPlugin, self).__init__(template, **kwargs)
 
     def _is_pending(self, taskid):
-        cmd = CommandLine('qstat')
-        cmd.inputs.args = '-j %d' % taskid
-        # check sge task
-        oldlevel = iflogger.level
-        iflogger.setLevel(logging.getLevelName('CRITICAL'))
-        result = cmd.run(ignore_exception=True)
-        iflogger.setLevel(oldlevel)
-        if result.runtime.stdout.startswith('='):
-            return True
-        return False
+        proc = subprocess.Popen(["qstat", '-j', taskid],
+                                stdout=subprocess.PIPE,
+                                stderr=subprocess.PIPE)
+        o, _ = proc.communicate()
+        return o.startswith('=')
 
     def _submit_batchtask(self, scriptfile, node):
         cmd = CommandLine('qsub', environ=os.environ.data)