Skip to content

Commit a503fc8

Browse files
committed
improve logging traces
1 parent 5d13229 commit a503fc8

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

nipype/pipeline/plugins/base.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -126,16 +126,15 @@ def run(self, graph, config, updatehash=False):
126126
notrun.append(self._clean_queue(jobid, graph,
127127
result=result))
128128

129-
logger.debug('Appending %d new tasks.' % len(toappend))
130129
if toappend:
131130
self.pending_tasks.extend(toappend)
132131
num_jobs = len(self.pending_tasks)
133-
logger.debug('Number of pending tasks: %d' % num_jobs)
132+
logger.debug('Tasks currently running (%d).', num_jobs)
134133
if num_jobs < self.max_jobs:
135134
self._send_procs_to_workers(updatehash=updatehash,
136135
graph=graph)
137136
else:
138-
logger.debug('Not submitting')
137+
logger.debug('Not submitting (max jobs reached)')
139138
self._wait()
140139

141140
self._remove_node_dirs()

0 commit comments

Comments
 (0)