Various changes.

[python_utils.git] / parallelize.py

diff --git a/parallelize.py b/parallelize.py
index 334dc4e992c56aebcad796d2f6696bd63b14653e..08220951a000e3ee9c24dcc908f54af1067ee265 100644 (file)
--- 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 = []