Distributed MapReduce in Python