[Findit] Add a sub-pipeline to analyze failures caused by DEPS rolls.

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 model.wf_analysis import WfAnalysis
 from model import wf_analysis_status
 from waterfall import build_failure_analysis
 from waterfall.base_pipeline import BasePipeline
 from model import wf_analysis_result_status
 
 
 def _GetResultAnalysisStatus(analysis_result):
   """Returns the status of the analysis result.
 
   We can dicide 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.
   """
   # Now we can only set the status based on if we found any suspected CL(s).
   # TODO: Add logic to decide the status after comparing with culprit CL(s).
   if not analysis_result or not analysis_result['failures']:
     return None
 
   for failure in analysis_result['failures']:
-    if failure['suspected_cls']: 
+    if failure['suspected_cls']:
       return wf_analysis_result_status.FOUND_UNTRIAGED
 
   return wf_analysis_result_status.NOT_FOUND_UNTRIAGED
 
 
 def _GetSuspectedCLs(analysis_result):
   """Returns the suspected CLs we found in analysis."""
   suspected_cls = []
   if not analysis_result or not analysis_result['failures']:
     return suspected_cls
 
   for failure in analysis_result['failures']:
     for suspected_cl in failure['suspected_cls']:
       cl_info = {
           'repo_name': suspected_cl['repo_name'],
           'revision': suspected_cl['revision'],
           'commit_position': suspected_cl['commit_position'],
           'url': suspected_cl['url']
       }
       if cl_info not in suspected_cls:
         suspected_cls.append(cl_info)
   return suspected_cls
 
 
 class IdentifyCulpritPipeline(BasePipeline):
   """A pipeline to identify culprit CLs for a build failure."""
 
   # Arguments number differs from overridden method - pylint: disable=W0221
-  def run(self, failure_info, change_logs, signals):
+  def run(self, failure_info, change_logs, deps_info, signals):
     """
     Args:
       failure_info (dict): Output of pipeline DetectFirstFailurePipeline.
       change_logs (dict): Output of pipeline PullChangelogPipeline.
       signals (dict): Output of pipeline ExtractSignalPipeline.
 
     Returns:
       The same dict as the returned value of function
       build_failure_analysis.AnalyzeBuildFailure.
     """
     master_name = failure_info['master_name']
     builder_name = failure_info['builder_name']
     build_number = failure_info['build_number']
 
     analysis_result = build_failure_analysis.AnalyzeBuildFailure(
-        failure_info, change_logs, signals)
+        failure_info, change_logs, deps_info, signals)
     analysis = WfAnalysis.Get(master_name, builder_name, build_number)
     analysis.result = analysis_result
     analysis.status = wf_analysis_status.ANALYZED
     analysis.result_status = _GetResultAnalysisStatus(analysis_result)
     analysis.suspected_cls = _GetSuspectedCLs(analysis_result)
     analysis.put()
 
     return analysis_result