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 |
new file mode 100644 |
index 0000000000000000000000000000000000000000..597b758fba9dc4e85f46b8baa1ef870c8d2db864 |
--- /dev/null |
+++ b/appengine/findit/waterfall/identify_culprit_pipeline.py |
@@ -0,0 +1,27 @@ |
+# 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.build_analysis import BuildAnalysis |
+from model.build_analysis_status import BuildAnalysisStatus |
+from waterfall import build_failure_analysis |
+from waterfall.base_pipeline import BasePipeline |
+ |
+ |
+class IdentifyCulpritPipeline(BasePipeline): |
+ |
+ # Arguments number differs from overridden method - pylint: disable=W0221 |
+ def run(self, failure_info, change_logs, signals): |
qyearsley
2015/01/16 22:55:26
A docstring would be helpful here.
stgao
2015/01/21 20:29:23
Done.
|
+ 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) |
+ analysis = BuildAnalysis.GetBuildAnalysis( |
+ master_name, builder_name, build_number) |
+ analysis.result = analysis_result |
+ analysis.status = BuildAnalysisStatus.ANALYZED |
+ analysis.put() |
+ |
+ return analysis_result |