File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -44,7 +44,7 @@ def mapreduce(
4444 is_executable (map_exe )
4545 is_executable (reduce_exe )
4646 if partitioner :
47- is_executable (partitioner )
47+ is_executable (partitioner , "2" )
4848
4949 # Create a tmp directory which will be automatically cleaned up
5050 with tempfile .TemporaryDirectory (prefix = "madoop-" ) as tmpdir :
@@ -157,7 +157,7 @@ def normalize_input_paths(input_path):
157157 return input_paths
158158
159159
160- def is_executable (exe ):
160+ def is_executable (exe , * args ):
161161 """Verify exe is executable and raise exception if it is not.
162162
163163 Execute exe with an empty string input and verify that it returns zero. We
@@ -168,7 +168,7 @@ def is_executable(exe):
168168 exe = pathlib .Path (exe ).resolve ()
169169 try :
170170 subprocess .run (
171- str (exe ),
171+ [ str (exe ), * args ] ,
172172 shell = False ,
173173 input = "" .encode (),
174174 stdout = subprocess .PIPE ,
You can’t perform that action at this time.
0 commit comments