[Findit] Refactor Findit pipeline.

appengine/findit/waterfall/identify_try_job_culprit_pipeline.py

Index: appengine/findit/waterfall/identify_try_job_culprit_pipeline.py
diff --git a/appengine/findit/waterfall/identify_try_job_culprit_pipeline.py b/appengine/findit/waterfall/identify_try_job_culprit_pipeline.py
index 84e5c5bc96db4d56d3ea8f750083250c9c81677b..e59c99796299dd9c27f06438fab9edfa1bc48c54 100644
--- a/appengine/findit/waterfall/identify_try_job_culprit_pipeline.py
+++ b/appengine/findit/waterfall/identify_try_job_culprit_pipeline.py
@@ -10,12 +10,12 @@ from google.appengine.ext import ndb
 from common.git_repository import GitRepository
 from common.http_client_appengine import HttpClientAppengine as HttpClient
 from common.pipeline_wrapper import BasePipeline
+from common.waterfall import failure_type
 from model import analysis_status
 from model import result_status
 from model.wf_analysis import WfAnalysis
 from model.wf_try_job import WfTryJob
 from model.wf_try_job_data import WfTryJobData
-from waterfall.try_job_type import TryJobType
 from waterfall.send_notification_for_culprit_pipeline import (
     SendNotificationForCulpritPipeline)
 
@@ -280,7 +280,7 @@ class IdentifyTryJobCulpritPipeline(BasePipeline):
     culprits = None
     if result and result.get('report'):
       try_job_data = WfTryJobData.Get(try_job_id)
-      if try_job_type == TryJobType.COMPILE:
+      if try_job_type == failure_type.COMPILE:
         # For compile failures, the try job will stop if one revision fails, so
         # the culprit will be the last revision in the result.
         failed_revision = _GetFailedRevisionFromCompileResult(result)
@@ -307,7 +307,7 @@ class IdentifyTryJobCulpritPipeline(BasePipeline):
       if culprits:
         result_to_update = (
             try_job_result.compile_results if
-            try_job_type == TryJobType.COMPILE else
+            try_job_type == failure_type.COMPILE else
             try_job_result.test_results)
         if (result_to_update and
             result_to_update[-1]['try_job_id'] == try_job_id):