[Findit] Refactor Findit pipeline.

appengine/findit/waterfall/monitor_try_job_pipeline.py

 # Copyright 2015 The Chromium Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
 from datetime import datetime
 import json
 import time
 
 from google.appengine.ext import ndb
 
 from common.pipeline_wrapper import BasePipeline
 from common.pipeline_wrapper import pipeline
 from common.waterfall import buildbucket_client
+from common.waterfall import failure_type
 from common.waterfall import try_job_error
 from common.waterfall.buildbucket_client import BuildbucketBuild
 from model import analysis_status
 from model.wf_try_job import WfTryJob
 from model.wf_try_job_data import WfTryJobData
 from waterfall import waterfall_config
-from waterfall.try_job_type import TryJobType
 
 
 def _MicrosecondsToDatetime(microseconds):
   """Returns a datetime given the number of microseconds, or None."""
   if microseconds:
     return datetime.utcfromtimestamp(float(microseconds) / 1000000)
   return None
 
 
 def _GetError(buildbucket_response, buildbucket_error, timed_out):
@@ skipping 127 matching lines @@
       self, status, master_name, builder_name, build_number, try_job_type,
       try_job_id, try_job_url, result_content=None):
     """Updates try job result based on response try job status and result."""
     result = {
         'report': result_content,
         'url': try_job_url,
         'try_job_id': try_job_id,
     }
 
     try_job_result = WfTryJob.Get(master_name, builder_name, build_number)
-    if try_job_type == TryJobType.COMPILE:
+    if try_job_type == failure_type.COMPILE:
       result_to_update = try_job_result.compile_results
     else:
       result_to_update = try_job_result.test_results
     if (result_to_update and
         result_to_update[-1]['try_job_id'] == try_job_id):
       result_to_update[-1].update(result)
     else:  # pragma: no cover
       # Normally result for current try job should've been saved in
       # schedule_try_job_pipeline, so this branch shouldn't be reached.
       result_to_update.append(result)
@@ skipping 67 matching lines @@
           already_set_started = True
 
       if time.time() > deadline:  # pragma: no cover
         _UpdateTryJobMetadata(try_job_data, start_time, build, error, True)
         # Explicitly abort the whole pipeline.
         raise pipeline.Abort(
             'Try job %s timed out after %d hours.' % (
                 try_job_id, timeout_hours))
 
       time.sleep(pipeline_wait_seconds)  # pragma: no cover