We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 63e58d0 commit 8f99238Copy full SHA for 8f99238
reframe/frontend/executors/policies.py
@@ -18,7 +18,7 @@
18
TaskEventListener, ABORT_REASONS)
19
20
21
-def values_len(d):
+def dictlist_len(d):
22
return functools.reduce(lambda l, r: l + len(r), d.values(), 0)
23
24
@@ -422,7 +422,7 @@ def exit(self):
422
num_polls = 0
423
t_start = datetime.now()
424
while (self._running_tasks or self._waiting_tasks or
425
- self._completed_tasks or values_len(self._ready_tasks)):
+ self._completed_tasks or dictlist_len(self._ready_tasks)):
426
getlogger().debug('running tasks: %s' % len(self._running_tasks))
427
num_polls += len(self._running_tasks)
428
try:
0 commit comments