Commits

Russell Power committed 30e616e

Return results...

Comments (0)

Files changed (1)

src/mycloud/mapreduce.py

                  for i in range(len(self.input)) ]
 
       self.controller.map(lambda m: m.run(), mappers)
-      self.controller.map(lambda r: r.invoke('wait'), reduce_tasks)
+      return self.controller.map(lambda r: r.invoke('wait'), reduce_tasks)
     except:
       logging.info('MapReduce failed.', exc_info=1)
       raise