X-Git-Url: https://wannabe.guru.org/gitweb/?a=blobdiff_plain;f=parallelize.py;h=d9c202faf00d56cf4cfc43e36c821998c249c7c4;hb=ed8fa2b10b0177b15b7423263bdd390efde2f0c8;hp=334dc4e992c56aebcad796d2f6696bd63b14653e;hpb=497fb9e21f45ec08e1486abaee6dfa7b20b8a691;p=python_utils.git diff --git a/parallelize.py b/parallelize.py index 334dc4e..d9c202f 100644 --- a/parallelize.py +++ b/parallelize.py @@ -6,13 +6,6 @@ from enum import Enum import functools import typing -import executors -import smart_future - -ps_count = 0 -thread_count = 0 -remote_count = 0 - class Method(Enum): THREAD = 1 @@ -64,6 +57,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 = []