| OLD | NEW |
| 1 # Copyright 2016 The Chromium Authors. All rights reserved. | 1 # Copyright 2016 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 import copy | 5 import copy |
| 6 import json | 6 import json |
| 7 import logging | 7 import logging |
| 8 | 8 |
| 9 from crash import monitoring | 9 from crash import monitoring |
| 10 | 10 |
| 11 from common import appengine_util | 11 from common import appengine_util |
| 12 from common import pubsub_util | 12 from common import pubsub_util |
| 13 from common.http_client_appengine import HttpClientAppengine | 13 from common.http_client_appengine import HttpClientAppengine |
| 14 from common.pipeline_wrapper import BasePipeline | 14 from common.pipeline_wrapper import BasePipeline |
| 15 from common.pipeline_wrapper import pipeline | 15 from common.pipeline_wrapper import pipeline |
| 16 from crash import findit_for_chromecrash | 16 from crash import findit_for_chromecrash |
| 17 from crash import findit_for_clusterfuzz | 17 from crash import findit_for_clusterfuzz |
| 18 from crash.type_enums import CrashClient | 18 from crash.type_enums import CrashClient |
| 19 from lib import time_util | 19 from libs import time_util |
| 20 from gae_libs.gitiles import cached_gitiles_repository | 20 from gae_libs.gitiles import cached_gitiles_repository |
| 21 from model import analysis_status | 21 from model import analysis_status |
| 22 | 22 |
| 23 | 23 |
| 24 # TODO(http://crbug.com/659346): write complete coverage tests for this. | 24 # TODO(http://crbug.com/659346): write complete coverage tests for this. |
| 25 def FinditForClientID(client_id, repository): # pragma: no cover | 25 def FinditForClientID(client_id, repository): # pragma: no cover |
| 26 """Construct a Findit object from a client id string specifying the class. | 26 """Construct a Findit object from a client id string specifying the class. |
| 27 | 27 |
| 28 We cannot pass Findit objects to the various methods in | 28 We cannot pass Findit objects to the various methods in |
| 29 ``crash.crash_pipeline``, because they are not JSON serializable. For | 29 ``crash.crash_pipeline``, because they are not JSON serializable. For |
| (...skipping 200 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 230 N.B., due to the structure of AppEngine pipelines, this method must | 230 N.B., due to the structure of AppEngine pipelines, this method must |
| 231 accept the same arguments as are passed to ``__init__``; however, | 231 accept the same arguments as are passed to ``__init__``; however, |
| 232 because they were already passed to ``__init__`` there's no use in | 232 because they were already passed to ``__init__`` there's no use in |
| 233 recieving them here. Thus, we discard all the arguments to this method | 233 recieving them here. Thus, we discard all the arguments to this method |
| 234 (except for ``self``, naturally). | 234 (except for ``self``, naturally). |
| 235 """ | 235 """ |
| 236 run_analysis = yield CrashAnalysisPipeline( | 236 run_analysis = yield CrashAnalysisPipeline( |
| 237 self._client_id, self._crash_identifiers) | 237 self._client_id, self._crash_identifiers) |
| 238 with pipeline.After(run_analysis): | 238 with pipeline.After(run_analysis): |
| 239 yield PublishResultPipeline(self._client_id, self._crash_identifiers) | 239 yield PublishResultPipeline(self._client_id, self._crash_identifiers) |
| OLD | NEW |