def test_failed_map(_):
  raise errors.FailJobError()
Always fail the map immediately.
dataset/ETHPy150Open GoogleCloudPlatform/appengine-mapreduce/python/test/mapreduce/mapreduce_pipeline_test.py/test_failed_map