Skip to content

Commit ababb64

Browse files
Add comment, pass actual num_reducers
1 parent 8f54e7d commit ababb64

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

madoop/mapreduce.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,8 +43,9 @@ def mapreduce(
4343
# Executable scripts must have valid shebangs
4444
is_executable(map_exe)
4545
is_executable(reduce_exe)
46+
# The partitioner executable expects to receive num_reducers as an arg
4647
if partitioner:
47-
is_executable(partitioner, "2")
48+
is_executable(partitioner, str(num_reducers))
4849

4950
# Create a tmp directory which will be automatically cleaned up
5051
with tempfile.TemporaryDirectory(prefix="madoop-") as tmpdir:

0 commit comments

Comments
 (0)