| OLD | NEW |
| 1 # Copyright 2015 The Chromium Authors. All rights reserved. | 1 # Copyright 2015 The Chromium Authors. All rights reserved. |
| 2 # Use of this source code is governed by a BSD-style license that can be | 2 # Use of this source code is governed by a BSD-style license that can be |
| 3 # found in the LICENSE file. | 3 # found in the LICENSE file. |
| 4 | 4 |
| 5 from pipeline_utils.appengine_third_party_pipeline_src_pipeline import pipeline | 5 from pipeline_utils.appengine_third_party_pipeline_python_src_pipeline \ |
| 6 import pipeline |
| 6 | 7 |
| 7 from common.git_repository import GitRepository | 8 from common.git_repository import GitRepository |
| 8 from common.http_client_appengine import HttpClientAppengine as HttpClient | 9 from common.http_client_appengine import HttpClientAppengine as HttpClient |
| 9 from waterfall.base_pipeline import BasePipeline | 10 from waterfall.base_pipeline import BasePipeline |
| 10 | 11 |
| 11 | 12 |
| 12 class PullChangelogPipeline(BasePipeline): | 13 class PullChangelogPipeline(BasePipeline): |
| 13 """A pipeline to pull change log of CLs.""" | 14 """A pipeline to pull change log of CLs.""" |
| 14 | 15 |
| 15 # TODO: for files in dependencies(blink, v8, skia, etc), use blame first. | 16 # TODO: for files in dependencies(blink, v8, skia, etc), use blame first. |
| (...skipping 20 matching lines...) Expand all Loading... |
| 36 | 37 |
| 37 for build in failure_info.get('builds', {}).values(): | 38 for build in failure_info.get('builds', {}).values(): |
| 38 for revision in build['blame_list']: | 39 for revision in build['blame_list']: |
| 39 change_log = self.GIT_REPO.GetChangeLog(revision) | 40 change_log = self.GIT_REPO.GetChangeLog(revision) |
| 40 if not change_log: # pragma: no cover | 41 if not change_log: # pragma: no cover |
| 41 raise pipeline.Retry('Failed to get change log for %s' % revision) | 42 raise pipeline.Retry('Failed to get change log for %s' % revision) |
| 42 | 43 |
| 43 change_logs[revision] = change_log.ToDict() | 44 change_logs[revision] = change_log.ToDict() |
| 44 | 45 |
| 45 return change_logs | 46 return change_logs |
| OLD | NEW |