summaryrefslogtreecommitdiff
path: root/parallelize.py
diff options
context:
space:
mode:
authorScott Gasch <[email protected]>2021-07-08 22:25:12 -0700
committerScott Gasch <[email protected]>2021-07-08 22:25:12 -0700
commit11eeb8574b7b4620ac6fd440cb251f8aa2458f5b (patch)
tree97f8e64eddd4528b01af58df269427814b889929 /parallelize.py
parente516059c716537259c601c022cc3bad44025385e (diff)
Reduce import scopes, remove cycles.
Diffstat (limited to 'parallelize.py')
-rw-r--r--parallelize.py6
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 = []