improve debugging traces

Author: oesteban

nipype/pipeline/plugins/base.py

@@ -105,7 +105,7 @@ def run(self, graph, config, updatehash=False):
             toappend = []
             # trigger callbacks for any pending results
             while self.pending_tasks:
-                logger.info('Processing %d pending tasks.', len(self.pending_tasks))
+                logger.debug('Processing %d pending tasks.', len(self.pending_tasks))
                 taskid, jobid = self.pending_tasks.pop()
                 try:
                     result = self._get_result(taskid)
@@ -168,7 +168,7 @@ def _clear_task(self, taskid):
         raise NotImplementedError
 
     def _clean_queue(self, jobid, graph, result=None):
-        logger.info('Clearing %d from queue', jobid)
+        logger.debug('Clearing %d from queue', jobid)
 
         if self._status_callback:
             self._status_callback(self.procs[jobid], 'exception')
@@ -194,8 +194,8 @@ def _submit_mapnode(self, jobid):
         self.mapnodes.append(jobid)
         mapnodesubids = self.procs[jobid].get_subnodes()
         numnodes = len(mapnodesubids)
-        logger.info('Adding %d jobs for mapnode %s' % (numnodes,
-                                                       self.procs[jobid]._id))
+        logger.debug('Adding %d jobs for mapnode %s',
+                     numnodes, self.procs[jobid]._id)
         for i in range(numnodes):
             self.mapnodesubids[self.depidx.shape[0] + i] = jobid
         self.procs.extend(mapnodesubids)

nipype/pipeline/plugins/multiproc.py

@@ -196,7 +196,7 @@ def _send_procs_to_workers(self, updatehash=False, graph=None):
         # Check available system resources by summing all threads and memory used
         free_memory_gb, free_processors = self._check_resources(self.pending_tasks)
 
-        logger.debug('Currently running %d tasks, and %d jobs ready. '
+        logger.info('Currently running %d tasks, and %d jobs ready. '
                      'Free memory (GB): %0.2f/%0.2f, Free processors: %d/%d',
                      len(self.pending_tasks), len(jobids),
                      free_memory_gb, self.memory_gb, free_processors, self.processors)