[Findit] Pipeline change to save suspected cls to data store.

appengine/findit/waterfall/identify_culprit_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
 
 from common.pipeline_wrapper import BasePipeline
+from model import analysis_approach_type
+from model import analysis_status
 from model import result_status
-from model import analysis_status
 from model.wf_analysis import WfAnalysis
 from waterfall import build_failure_analysis
+from waterfall import suspected_cl_util
 
 
 def _GetResultAnalysisStatus(analysis_result):
   """Returns the status of the analysis result.
 
   We can decide the status based on:
     1. whether we found any suspected CL(s).
     2. whether we have triaged the failure.
     3. whether our analysis result is the same as triaged result.
   """
@@ skipping 52 matching lines @@
         failure_info, change_logs, deps_info, signals)
     analysis = WfAnalysis.Get(master_name, builder_name, build_number)
     analysis.build_completed = build_completed
     analysis.result = analysis_result
     analysis.status = analysis_status.COMPLETED
     analysis.result_status = _GetResultAnalysisStatus(analysis_result)
     analysis.suspected_cls = _GetSuspectedCLs(analysis_result)
     analysis.end_time = datetime.utcnow()
     analysis.put()
 
-    return analysis_result
+    # Creates and/or updates WfSuspectedCL entities for suspected cls.
+    for suspected_cl in analysis.suspected_cls:
+      suspected_cl_util.UpdateSuspectedCL(
+          analysis_approach_type.HEURISTIC, master_name, builder_name,
+          build_number, failure_info['failure_type'], suspected_cl['repo_name'],
+          suspected_cl['revision'], suspected_cl['commit_position'])
+    return analysis_result