diff options
| author | Scott Gasch <[email protected]> | 2021-07-08 22:25:12 -0700 |
|---|---|---|
| committer | Scott Gasch <[email protected]> | 2021-07-08 22:25:12 -0700 |
| commit | 11eeb8574b7b4620ac6fd440cb251f8aa2458f5b (patch) | |
| tree | 97f8e64eddd4528b01af58df269427814b889929 /parallelize.py | |
| parent | e516059c716537259c601c022cc3bad44025385e (diff) | |
Reduce import scopes, remove cycles.
Diffstat (limited to 'parallelize.py')
| -rw-r--r-- | parallelize.py | 6 |
1 files changed, 3 insertions, 3 deletions
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 = [] |
