Chromium Code Reviews| 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 testing_utils import testing | |
| 6 | |
| 7 from common import buildbucket_client | 5 from common import buildbucket_client |
| 6 from model.test import configured_test_case | |
| 8 from model.wf_try_job import WfTryJob | 7 from model.wf_try_job import WfTryJob |
| 9 from waterfall import waterfall_config | |
| 10 from waterfall.schedule_try_job_pipeline import ScheduleTryJobPipeline | 8 from waterfall.schedule_try_job_pipeline import ScheduleTryJobPipeline |
| 11 from waterfall.try_job_type import TryJobType | 9 from waterfall.try_job_type import TryJobType |
| 12 | 10 |
| 13 | 11 |
| 14 class ScheduleTryjobPipelineTest(testing.AppengineTestCase): | 12 class ScheduleTryjobPipelineTest(configured_test_case.ConfiguredTestCase): |
| 15 | 13 |
| 16 def _Mock_GetTrybotForWaterfallBuilder(self, *_): | 14 def setUp(self): |
|
stgao
2016/03/30 01:06:30
This could be removed now.
lijeffrey
2016/03/30 23:28:34
Done.
| |
| 17 def MockedGetTrybotForWaterfallBuilder(*_): | 15 super(ScheduleTryjobPipelineTest, self).setUp() |
| 18 return 'linux_chromium_variable', 'master.tryserver.chromium.linux' | |
| 19 self.mock(waterfall_config, 'GetTrybotForWaterfallBuilder', | |
| 20 MockedGetTrybotForWaterfallBuilder) | |
| 21 | 16 |
| 22 def _Mock_TriggerTryJobs(self, responses): | 17 def _Mock_TriggerTryJobs(self, responses): |
| 23 def MockedTriggerTryJobs(*_): | 18 def MockedTriggerTryJobs(*_): |
| 24 results = [] | 19 results = [] |
| 25 for response in responses: | 20 for response in responses: |
| 26 if response.get('error'): # pragma: no cover | 21 if response.get('error'): # pragma: no cover |
| 27 results.append(( | 22 results.append(( |
| 28 buildbucket_client.BuildbucketError(response['error']), None)) | 23 buildbucket_client.BuildbucketError(response['error']), None)) |
| 29 else: | 24 else: |
| 30 results.append(( | 25 results.append(( |
| (...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 89 | 84 |
| 90 responses = [ | 85 responses = [ |
| 91 { | 86 { |
| 92 'build': { | 87 'build': { |
| 93 'id': '1', | 88 'id': '1', |
| 94 'url': 'url', | 89 'url': 'url', |
| 95 'status': 'SCHEDULED', | 90 'status': 'SCHEDULED', |
| 96 } | 91 } |
| 97 } | 92 } |
| 98 ] | 93 ] |
| 99 self._Mock_GetTrybotForWaterfallBuilder(master_name, builder_name) | 94 |
| 100 self._Mock_TriggerTryJobs(responses) | 95 self._Mock_TriggerTryJobs(responses) |
| 101 | 96 |
| 102 WfTryJob.Create(master_name, builder_name, build_number).put() | 97 WfTryJob.Create(master_name, builder_name, build_number).put() |
| 103 | 98 |
| 104 try_job_pipeline = ScheduleTryJobPipeline() | 99 try_job_pipeline = ScheduleTryJobPipeline() |
| 105 try_job_id = try_job_pipeline.run( | 100 try_job_id = try_job_pipeline.run( |
| 106 master_name, builder_name, build_number, good_revision, bad_revision, | 101 master_name, builder_name, build_number, good_revision, bad_revision, |
| 107 TryJobType.COMPILE, None, None) | 102 TryJobType.COMPILE, None, None) |
| 108 | 103 |
| 109 try_job = WfTryJob.Get(master_name, builder_name, build_number) | 104 try_job = WfTryJob.Get(master_name, builder_name, build_number) |
| (...skipping 13 matching lines...) Expand all Loading... | |
| 123 | 118 |
| 124 responses = [ | 119 responses = [ |
| 125 { | 120 { |
| 126 'build': { | 121 'build': { |
| 127 'id': '1', | 122 'id': '1', |
| 128 'url': 'url', | 123 'url': 'url', |
| 129 'status': 'SCHEDULED', | 124 'status': 'SCHEDULED', |
| 130 } | 125 } |
| 131 } | 126 } |
| 132 ] | 127 ] |
| 133 self._Mock_GetTrybotForWaterfallBuilder(master_name, builder_name) | |
| 134 self._Mock_TriggerTryJobs(responses) | 128 self._Mock_TriggerTryJobs(responses) |
| 135 | 129 |
| 136 WfTryJob.Create(master_name, builder_name, build_number).put() | 130 WfTryJob.Create(master_name, builder_name, build_number).put() |
| 137 | 131 |
| 138 try_job_pipeline = ScheduleTryJobPipeline() | 132 try_job_pipeline = ScheduleTryJobPipeline() |
| 139 try_job_id = try_job_pipeline.run( | 133 try_job_id = try_job_pipeline.run( |
| 140 master_name, builder_name, build_number, good_revision, bad_revision, | 134 master_name, builder_name, build_number, good_revision, bad_revision, |
| 141 TryJobType.TEST, None, targeted_tests) | 135 TryJobType.TEST, None, targeted_tests) |
| 142 | 136 |
| 143 try_job = WfTryJob.Get(master_name, builder_name, build_number) | 137 try_job = WfTryJob.Get(master_name, builder_name, build_number) |
| 144 self.assertEqual('1', try_job_id) | 138 self.assertEqual('1', try_job_id) |
| 145 self.assertEqual('1', try_job.test_results[-1]['try_job_id']) | 139 self.assertEqual('1', try_job.test_results[-1]['try_job_id']) |
| OLD | NEW |