[engine] make Uncaught Exception steps purple.

recipe_engine/run.py

 # Copyright 2017 The LUCI Authors. All rights reserved.
 # Use of this source code is governed under the Apache License, Version 2.0
 # that can be found in the LICENSE file.
 
 """Entry point for fully-annotated builds.
 
 This script is part of the effort to move all builds to annotator-based
 systems. Any builder configured to use the AnnotatorFactory.BaseFactory()
 found in scripts/master/factory/annotator_factory.py executes a single
 AddAnnotatedScript step. That step (found in annotator_commands.py) calls
@@ skipping 521 matching lines @@
         recipe_result.result['recipe_result'], indent=2)
     if result_filename:
       with open(result_filename, 'w') as f:
         f.write(result_string)
     with stream_engine.make_step_stream('recipe result') as s:
       with s.new_log_stream('result') as l:
         l.write_split(result_string)
 
   if 'traceback' in recipe_result.result:
     with stream_engine.make_step_stream('Uncaught Exception') as s:
+      s.set_step_status('EXCEPTION')
       with s.new_log_stream('exception') as l:
         for line in recipe_result.result['traceback']:
           l.write_line(line)
 
   if 'reason' in recipe_result.result:
     with stream_engine.make_step_stream('Failure reason') as s:
+      s.set_step_status('FAILURE')
       with s.new_log_stream('reason') as l:
         for line in recipe_result.result['reason'].splitlines():
           l.write_line(line)
 
   if 'status_code' in recipe_result.result:
     return recipe_result.result['status_code']
   else:
     return 0
 
 
 def new_handle_recipe_return(result, result_filename, stream_engine):
   if result_filename:
     with open(result_filename, 'w') as fil:
       fil.write(jsonpb.MessageToJson(
           result, including_default_value_fields=True))
 
   if result.json_result:
     with stream_engine.make_step_stream('recipe result') as s:
       with s.new_log_stream('result') as l:
         l.write_split(result.json_result)
 
   if result.HasField('failure'):
     f = result.failure
     if f.HasField('exception'):
       with stream_engine.make_step_stream('Uncaught Exception') as s:
+        s.set_step_status('EXCEPTION')
         s.add_step_text(f.human_reason)
         with s.new_log_stream('exception') as l:
           for line in f.exception.traceback:
             l.write_line(line)
     # TODO(martiniss): Remove this code once calling code handles these states
     elif f.HasField('timeout'):
       with stream_engine.make_step_stream('Step Timed Out') as s:
+        s.set_step_status('FAILURE')
         with s.new_log_stream('timeout_s') as l:
           l.write_line(f.timeout.timeout_s)
     elif f.HasField('step_data'):
       with stream_engine.make_step_stream('Invalid Step Data Access') as s:
+        s.set_step_status('FAILURE')
         with s.new_log_stream('step') as l:
           l.write_line(f.step_data.step)
 
     with stream_engine.make_step_stream('Failure reason') as s:
+      s.set_step_status('FAILURE')
       with s.new_log_stream('reason') as l:
         l.write_split(f.human_reason)
 
     return 1
 
   return 0
 
 
 # Map of arguments_pb2.Property "value" oneof conversion functions.
 #
@@ skipping 121 matching lines @@
       ret = run_steps(
           properties, stream_engine,
           step_runner.SubprocessStepRunner(stream_engine, engine_flags),
           universe_view, engine_flags=engine_flags,
           emit_initial_properties=emit_initial_properties)
     finally:
       os.chdir(old_cwd)
 
     return handle_recipe_return(
         ret, args.output_result_json, stream_engine, engine_flags)