#
# Author: Alina Quereilhac <alina.quereilhac@inria.fr>
+from six import next
+
from nepi.util import guid
from nepi.util.parallel import ParallelRun
from nepi.util.timefuncs import tnow, tdiffsec, stabsformat, tsformat
"""
# Get next available guid
+ # xxx_next_hiccup
guid = self._guid_generator.next(guid)
# Instantiate RM
new_group = False
if not group:
new_group = True
+ # xxx_next_hiccup
group = self._group_id_generator.next()
if group not in self._groups:
try:
self._cond.acquire()
- task = self._scheduler.next()
+ task = next(self._scheduler)
if not task:
# No task to execute. Wait for a new task to be scheduled.