X-Git-Url: https://wannabe.guru.org/gitweb/?a=blobdiff_plain;f=parallelize.py;h=08220951a000e3ee9c24dcc908f54af1067ee265;hb=957c962294cde93c4c649ed18dedd16df071878d;hp=334dc4e992c56aebcad796d2f6696bd63b14653e;hpb=497fb9e21f45ec08e1486abaee6dfa7b20b8a691;p=python_utils.git diff --git a/parallelize.py b/parallelize.py index 334dc4e..0822095 100644 --- a/parallelize.py +++ b/parallelize.py @@ -6,9 +6,6 @@ from enum import Enum import functools import typing -import executors -import smart_future - ps_count = 0 thread_count = 0 remote_count = 0 @@ -64,6 +61,9 @@ def parallelize( @functools.wraps(funct) def inner_wrapper(*args, **kwargs): + import executors + import smart_future + # Look for as of yet unresolved arguments in _funct's # argument list and resolve them now. newargs = []