@@ -65,14 +65,16 @@ def install_given_reqs(
65
65
# pre allocate installed package names
66
66
installed = [None ] * len (to_install )
67
67
install_args = [install_options , global_options , dict (
68
- root = root , home = home , prefix = prefix , warn_script_location = warn_script_location ,
69
- use_user_site = use_user_site , pycompile = pycompile )]
68
+ root = root , home = home , prefix = prefix ,
69
+ warn_script_location = warn_script_location ,
70
+ use_user_site = use_user_site , pycompile = pycompile )]
70
71
71
72
if Pool is not None :
72
73
# first let's try to install in parallel, if we fail we do it by order.
73
74
pool = Pool ()
74
75
try :
75
- pool_result = pool .starmap_async (__single_install , [(install_args , r ) for r in to_install ])
76
+ pool_result = pool .starmap_async (
77
+ __single_install , [(install_args , r ) for r in to_install ])
76
78
# python 2.7 timeout=None will not catch KeyboardInterrupt
77
79
installed = pool_result .get (timeout = 999999 )
78
80
except (KeyboardInterrupt , SystemExit ):
@@ -87,7 +89,8 @@ def install_given_reqs(
87
89
with indent_log ():
88
90
for i , requirement in enumerate (to_install ):
89
91
if installed [i ] is None :
90
- installed [i ] = __single_install (install_args , requirement , allow_raise = True )
92
+ installed [i ] = __single_install (
93
+ install_args , requirement , allow_raise = True )
91
94
92
95
return [i for i in installed if i is not None ]
93
96
0 commit comments