diff --git a/pyontutils/__init__.py b/pyontutils/__init__.py index f9b925bf..8dcfa7de 100644 --- a/pyontutils/__init__.py +++ b/pyontutils/__init__.py @@ -1 +1 @@ -__version__ = '0.1.31' +__version__ = '0.1.32' diff --git a/pyontutils/utils.py b/pyontutils/utils.py index 03e02afe..d331b105 100644 --- a/pyontutils/utils.py +++ b/pyontutils/utils.py @@ -461,10 +461,12 @@ def inner(generator): time_est = len(funclist) / rate chunks = chunk_list(funclist, size) lc = len(chunks) - print(f'Time estimate: {time_est} rate: {rate}Hz ' - f'func: {funclist[0]} args: {len(funclist)} ' - f'chunks: {lc} size: {size}') - generator = (lambda:list(limited_gen(chunk, smooth_offset=(i % lc)/lc, time_est=time_est, debug=debug, thread=i)) # this was the slowdown culpret + log.info(f'Time estimate: {time_est} rate: {rate}Hz ' + f'func: {funclist[0]} args: {len(funclist)} ' + f'chunks: {lc} size: {size}') + generator = (lambda _c=chunk, _i=i: list(limited_gen( + _c, smooth_offset=(_i % lc)/lc, time_est=time_est, + debug=debug, thread=_i)) for i, chunk in enumerate(sorted(chunks, key=len, reverse=True))) async def future_loop(future_):