215
215
outputer = OutputPyJSON(open(self.tmp_file, 'w'))
216
216
for map_red_type in ['multi_process']:
217
217
config = StringIO(u"""type_of_dataflow="%s" """ % map_red_type)
219
218
with self.assertRaises(Exception):
220
219
Go(inputer, transformer, merger, outputer, config, \
221
220
command_line_args = False)