FIX: PEP8 - E271 multiple spaces after keyword

Author: miykael

examples/dmri_group_connectivity_mrtrix.py

@@ -55,7 +55,7 @@
 
 import nipype.interfaces.fsl as fsl
 import nipype.interfaces.freesurfer as fs    # freesurfer
-import  os.path as op                     # system functions
+import os.path as op                     # system functions
 import cmp
 from nipype.workflows.dmri.mrtrix.group_connectivity import create_group_connectivity_pipeline
 from nipype.workflows.dmri.connectivity.group_connectivity import (create_merge_network_results_by_group_workflow, create_merge_group_network_results_workflow, create_average_networks_by_group_workflow)

nipype/interfaces/diffusion_toolkit/dti.py

@@ -68,11 +68,11 @@ class DTIRecon(CommandLine):
 
     def _create_gradient_matrix(self, bvecs_file, bvals_file):
         _gradient_matrix_file = 'gradient_matrix.txt'
-        bvals = [val for val in  re.split('\s+', open(bvals_file).readline().strip())]
+        bvals = [val for val in re.split('\s+', open(bvals_file).readline().strip())]
         bvecs_f = open(bvecs_file)
-        bvecs_x = [val for val in  re.split('\s+', bvecs_f.readline().strip())]
-        bvecs_y = [val for val in  re.split('\s+', bvecs_f.readline().strip())]
-        bvecs_z = [val for val in  re.split('\s+', bvecs_f.readline().strip())]
+        bvecs_x = [val for val in re.split('\s+', bvecs_f.readline().strip())]
+        bvecs_y = [val for val in re.split('\s+', bvecs_f.readline().strip())]
+        bvecs_z = [val for val in re.split('\s+', bvecs_f.readline().strip())]
         bvecs_f.close()
         gradient_matrix_f = open(_gradient_matrix_file, 'w')
         for i in range(len(bvals)):

nipype/interfaces/diffusion_toolkit/odf.py

@@ -64,11 +64,11 @@ class HARDIMat(CommandLine):
 
     def _create_gradient_matrix(self, bvecs_file, bvals_file):
         _gradient_matrix_file = 'gradient_matrix.txt'
-        bvals = [val for val in  re.split('\s+', open(bvals_file).readline().strip())]
+        bvals = [val for val in re.split('\s+', open(bvals_file).readline().strip())]
         bvecs_f = open(bvecs_file)
-        bvecs_x = [val for val in  re.split('\s+', bvecs_f.readline().strip())]
-        bvecs_y = [val for val in  re.split('\s+', bvecs_f.readline().strip())]
-        bvecs_z = [val for val in  re.split('\s+', bvecs_f.readline().strip())]
+        bvecs_x = [val for val in re.split('\s+', bvecs_f.readline().strip())]
+        bvecs_y = [val for val in re.split('\s+', bvecs_f.readline().strip())]
+        bvecs_z = [val for val in re.split('\s+', bvecs_f.readline().strip())]
         bvecs_f.close()
         gradient_matrix_f = open(_gradient_matrix_file, 'w')
         for i in range(len(bvals)):

nipype/interfaces/freesurfer/preprocess.py

@@ -538,7 +538,7 @@ def cmdline(self):
                 single_cmd = '%s %s %s' % (self.cmd, infile,
                                            os.path.join(outdir, outfile))
                 cmd.extend([single_cmd])
-        return  '; '.join(cmd)
+        return '; '.join(cmd)
 
 
 class ResampleInputSpec(FSTraitedSpec):

nipype/pipeline/engine.py

@@ -110,7 +110,7 @@ def format_node(node, format='python', include_config=False):
         if args:
             filled_args = []
             for arg in args:
-                if  hasattr(node._interface, '_%s' % arg):
+                if hasattr(node._interface, '_%s' % arg):
                     filled_args.append('%s=%s' % (arg, getattr(node._interface,
                                                                '_%s' % arg)))
             args = ', '.join(filled_args)

nipype/pipeline/plugins/condor.py

@@ -40,7 +40,7 @@ def __init__(self, **kwargs):
         if 'plugin_args' in kwargs and kwargs['plugin_args']:
             if 'retry_timeout' in kwargs['plugin_args']:
                 self._retry_timeout = kwargs['plugin_args']['retry_timeout']
-            if  'max_tries' in kwargs['plugin_args']:
+            if 'max_tries' in kwargs['plugin_args']:
                 self._max_tries = kwargs['plugin_args']['max_tries']
         super(CondorPlugin, self).__init__(template, **kwargs)
 

nipype/pipeline/plugins/lsf.py

@@ -34,7 +34,7 @@ def __init__(self, **kwargs):
         if 'plugin_args' in kwargs and kwargs['plugin_args']:
             if 'retry_timeout' in kwargs['plugin_args']:
                 self._retry_timeout = kwargs['plugin_args']['retry_timeout']
-            if  'max_tries' in kwargs['plugin_args']:
+            if 'max_tries' in kwargs['plugin_args']:
                 self._max_tries = kwargs['plugin_args']['max_tries']
             if 'bsub_args' in kwargs['plugin_args']:
                 self._bsub_args = kwargs['plugin_args']['bsub_args']

nipype/pipeline/plugins/pbs.py

@@ -36,9 +36,9 @@ def __init__(self, **kwargs):
         if 'plugin_args' in kwargs and kwargs['plugin_args']:
             if 'retry_timeout' in kwargs['plugin_args']:
                 self._retry_timeout = kwargs['plugin_args']['retry_timeout']
-            if  'max_tries' in kwargs['plugin_args']:
+            if 'max_tries' in kwargs['plugin_args']:
                 self._max_tries = kwargs['plugin_args']['max_tries']
-            if  'max_jobname_len' in kwargs['plugin_args']:
+            if 'max_jobname_len' in kwargs['plugin_args']:
                 self._max_jobname_len = kwargs['plugin_args']['max_jobname_len']
         super(PBSPlugin, self).__init__(template, **kwargs)
 
@@ -49,7 +49,7 @@ def _is_pending(self, taskid):
                                 stderr=subprocess.PIPE)
         _, e = proc.communicate()
         errmsg = 'Unknown Job Id'  # %s' % taskid
-        return  errmsg not in e
+        return errmsg not in e
 
     def _submit_batchtask(self, scriptfile, node):
         cmd = CommandLine('qsub', environ=os.environ.data,

nipype/pipeline/plugins/slurm.py

@@ -45,7 +45,7 @@ def __init__(self, **kwargs):
         if 'plugin_args' in kwargs and kwargs['plugin_args']:
             if 'retry_timeout' in kwargs['plugin_args']:
                 self._retry_timeout = kwargs['plugin_args']['retry_timeout']
-            if  'max_tries' in kwargs['plugin_args']:
+            if 'max_tries' in kwargs['plugin_args']:
                 self._max_tries = kwargs['plugin_args']['max_tries']
             if 'template' in kwargs['plugin_args']:
                 self._template = kwargs['plugin_args']['template']

nipype/pipeline/plugins/slurmgraph.py

@@ -45,7 +45,7 @@ def __init__(self, **kwargs):
         if 'plugin_args' in kwargs and kwargs['plugin_args']:
             if 'retry_timeout' in kwargs['plugin_args']:
                 self._retry_timeout = kwargs['plugin_args']['retry_timeout']
-            if  'max_tries' in kwargs['plugin_args']:
+            if 'max_tries' in kwargs['plugin_args']:
                 self._max_tries = kwargs['plugin_args']['max_tries']
             if 'template' in kwargs['plugin_args']:
                 self._template = kwargs['plugin_args']['template']