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

appengine/findit/waterfall/identify_culprit_pipeline.py

Index: appengine/findit/waterfall/identify_culprit_pipeline.py
diff --git a/appengine/findit/waterfall/identify_culprit_pipeline.py b/appengine/findit/waterfall/identify_culprit_pipeline.py
index caafe549d78dd026f236ec44569e92fa44d387d4..509c003c11d7a3e8696cf89fe3b6203f93105615 100644
--- a/appengine/findit/waterfall/identify_culprit_pipeline.py
+++ b/appengine/findit/waterfall/identify_culprit_pipeline.py
@@ -5,10 +5,12 @@
 from datetime import datetime
 
 from common.pipeline_wrapper import BasePipeline
-from model import result_status
+from model import analysis_approach_type
 from model import analysis_status
+from model import result_status
 from model.wf_analysis import WfAnalysis
 from waterfall import build_failure_analysis
+from waterfall import suspected_cl_util
 
 
 def _GetResultAnalysisStatus(analysis_result):
@@ -81,4 +83,10 @@ class IdentifyCulpritPipeline(BasePipeline):
     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