restore those __array__()

Author: oesteban

nipype/pipeline/plugins/base.py

@@ -361,7 +361,7 @@ def _send_procs_to_workers(self, updatehash=False, graph=None):
                 break
             # Check to see if a job is available
             jobids = np.flatnonzero(
-                ~self.proc_done & (np.sum(self.depidx, axis=0) == 0))
+                ~self.proc_done & (self.depidx.sum(axis=0) == 0).__array__())
 
             if len(jobids) > 0:
                 # send all available jobs
@@ -478,7 +478,8 @@ def _remove_node_dirs(self):
         """Removes directories whose outputs have already been used up
         """
         if str2bool(self._config['execution']['remove_node_directories']):
-            for idx in np.nonzero(np.sum(self.refidx, axis=1) == 0)[0]:
+            for idx in np.nonzero(
+                                 (self.refidx.sum(axis=1) == 0).__array__())[0]:
                 if idx in self.mapnodesubids:
                     continue
                 if self.proc_done[idx] and (not self.proc_pending[idx]):

nipype/pipeline/plugins/multiproc.py

@@ -200,7 +200,7 @@ def _send_procs_to_workers(self, updatehash=False, graph=None):
 
         # Check all jobs without dependency not run
         jobids = np.flatnonzero(
-            ~self.proc_done & (np.sum(self.depidx, axis=0) == 0))
+            ~self.proc_done & (self.depidx.sum(axis=0) == 0).__array__())
 
         # Sort jobs ready to run first by memory and then by number of threads
         # The most resource consuming jobs run first