def test_failed_map(_):
  raise errors.FailJobError()
Emit a record.
dataset/ETHPy150Open GoogleCloudPlatform/appengine-mapreduce/python/test/mapreduce/mapreduce_pipeline_test.py/test_failed_map--crossover with--dataset/ETHPy150Open babble/babble/include/jython/Lib/logging/__init__.py/StreamHandler.emit