flake8 backport
@@ -26,7 +26,8 @@ elif "mkl_core" in config_info:
"Multiprocessing will be disabled. https://github.com/joblib/joblib/issues/138")
MULTIPROCESSING = False
elif platform.system() == 'Windows':
- logger.warning("Dedupe does not currently support multiprocessing on Windows")
+ logger.warning(
+ "Dedupe does not currently support multiprocessing on Windows")
MULTIPROCESSING = False
if MULTIPROCESSING:
@@ -38,7 +39,5 @@ if MULTIPROCESSING :
else:
if not hasattr(threading.current_thread(), "_children"):
threading.current_thread()._children = weakref.WeakKeyDictionary()
- from multiprocessing.dummy import Process, Pool, Queue
+ from multiprocessing.dummy import Process, Pool, Queue # noqa: F401
SimpleQueue = Queue
-
-
