do not access __array__() of matrices (revise)

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).astype(bool))
+                ~self.proc_done & (np.sum(self.depidx, axis=0) == 0))
 
             if len(jobids) > 0:
                 # send all available jobs

nipype/pipeline/plugins/multiproc.py

@@ -169,7 +169,7 @@ def _send_procs_to_workers(self, updatehash=False, graph=None):
 
         # Check to see if a job is available
         currently_running_jobids = np.flatnonzero(
-            ~self.proc_pending & ~np.sum(self.depidx, axis=0).astype(bool))
+            ~self.proc_pending & (np.sum(self.depidx, axis=0) == 0))
 
         # Check available system resources by summing all threads and memory used
         busy_memory_gb = 0
@@ -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).astype(bool))
+            ~self.proc_done & (np.sum(self.depidx, axis=0) == 0))
 
         # Sort jobs ready to run first by memory and then by number of threads
         # The most resource consuming jobs run first