| 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 datetime | 5 import datetime |
| 6 | 6 |
| 7 from model import analysis_status | 7 from model import analysis_status |
| 8 from model.wf_swarming_task import WfSwarmingTask | 8 from model.wf_swarming_task import WfSwarmingTask |
| 9 from waterfall import process_swarming_task_result_pipeline | 9 from waterfall import process_swarming_task_result_pipeline |
| 10 from waterfall import swarming_util | 10 from waterfall import swarming_util |
| (...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 103 'reliable_tests': ['TestSuite1.test3'] | 103 'reliable_tests': ['TestSuite1.test3'] |
| 104 } | 104 } |
| 105 | 105 |
| 106 | 106 |
| 107 class ProcessSwarmingTaskResultPipelineTest(wf_testcase.WaterfallTestCase): | 107 class ProcessSwarmingTaskResultPipelineTest(wf_testcase.WaterfallTestCase): |
| 108 | 108 |
| 109 def _MockedGetSwarmingTaskResultById(self, task_id, _): | 109 def _MockedGetSwarmingTaskResultById(self, task_id, _): |
| 110 swarming_task_results = { | 110 swarming_task_results = { |
| 111 'task_id1': { | 111 'task_id1': { |
| 112 'state': 'COMPLETED', | 112 'state': 'COMPLETED', |
| 113 'exit_code': '1', |
| 113 'tags': [ | 114 'tags': [ |
| 114 'priority:25', | 115 'priority:25', |
| 115 'ref_name:abc_tests' | 116 'ref_name:abc_tests' |
| 116 ], | 117 ], |
| 117 'outputs_ref': { | 118 'outputs_ref': { |
| 118 'isolatedserver': _ISOLATED_SERVER, | 119 'isolatedserver': _ISOLATED_SERVER, |
| 119 'namespace': 'default-gzip', | 120 'namespace': 'default-gzip', |
| 120 'isolated': 'shard1_isolated' | 121 'isolated': 'shard1_isolated' |
| 121 }, | 122 }, |
| 122 'created_ts': '2016-02-10T18:32:06.538220', | 123 'created_ts': '2016-02-10T18:32:06.538220', |
| (...skipping 112 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 235 self.assertEqual(self.step_name, step_name) | 236 self.assertEqual(self.step_name, step_name) |
| 236 self.assertEqual('abc_tests', task_info[0]) | 237 self.assertEqual('abc_tests', task_info[0]) |
| 237 self.assertEqual([], task_info[1]) | 238 self.assertEqual([], task_info[1]) |
| 238 | 239 |
| 239 task = WfSwarmingTask.Get( | 240 task = WfSwarmingTask.Get( |
| 240 self.master_name, self.builder_name, self.build_number, self.step_name) | 241 self.master_name, self.builder_name, self.build_number, self.step_name) |
| 241 | 242 |
| 242 self.assertEqual(analysis_status.ERROR, task.status) | 243 self.assertEqual(analysis_status.ERROR, task.status) |
| 243 self.assertEqual({}, task.tests_statuses) | 244 self.assertEqual({}, task.tests_statuses) |
| 244 self.assertEqual({}, task.classified_tests) | 245 self.assertEqual({}, task.classified_tests) |
| OLD | NEW |