Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(528)

Side by Side Diff: appengine/findit/waterfall/test/schedule_try_job_pipeline_test.py

Issue 1836293002: [Findit] Adding central config test class for unit tests (Closed) Base URL: https://chromium.googlesource.com/infra/infra.git@master
Patch Set: Addressing comments Created 4 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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
8 from model.wf_try_job import WfTryJob 6 from model.wf_try_job import WfTryJob
9 from waterfall import waterfall_config
10 from waterfall.schedule_try_job_pipeline import ScheduleTryJobPipeline 7 from waterfall.schedule_try_job_pipeline import ScheduleTryJobPipeline
8 from waterfall.test import wf_configured_test_case
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(
15 13 wf_configured_test_case.WaterfallConfiguredTestCase):
16 def _Mock_GetTrybotForWaterfallBuilder(self, *_):
17 def MockedGetTrybotForWaterfallBuilder(*_):
18 return 'linux_chromium_variable', 'master.tryserver.chromium.linux'
19 self.mock(waterfall_config, 'GetTrybotForWaterfallBuilder',
20 MockedGetTrybotForWaterfallBuilder)
21 14
22 def _Mock_TriggerTryJobs(self, responses): 15 def _Mock_TriggerTryJobs(self, responses):
23 def MockedTriggerTryJobs(*_): 16 def MockedTriggerTryJobs(*_):
24 results = [] 17 results = []
25 for response in responses: 18 for response in responses:
26 if response.get('error'): # pragma: no cover 19 if response.get('error'): # pragma: no cover
27 results.append(( 20 results.append((
28 buildbucket_client.BuildbucketError(response['error']), None)) 21 buildbucket_client.BuildbucketError(response['error']), None))
29 else: 22 else:
30 results.append(( 23 results.append((
(...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after
89 82
90 responses = [ 83 responses = [
91 { 84 {
92 'build': { 85 'build': {
93 'id': '1', 86 'id': '1',
94 'url': 'url', 87 'url': 'url',
95 'status': 'SCHEDULED', 88 'status': 'SCHEDULED',
96 } 89 }
97 } 90 }
98 ] 91 ]
99 self._Mock_GetTrybotForWaterfallBuilder(master_name, builder_name) 92
100 self._Mock_TriggerTryJobs(responses) 93 self._Mock_TriggerTryJobs(responses)
101 94
102 WfTryJob.Create(master_name, builder_name, build_number).put() 95 WfTryJob.Create(master_name, builder_name, build_number).put()
103 96
104 try_job_pipeline = ScheduleTryJobPipeline() 97 try_job_pipeline = ScheduleTryJobPipeline()
105 try_job_id = try_job_pipeline.run( 98 try_job_id = try_job_pipeline.run(
106 master_name, builder_name, build_number, good_revision, bad_revision, 99 master_name, builder_name, build_number, good_revision, bad_revision,
107 TryJobType.COMPILE, None, None) 100 TryJobType.COMPILE, None, None)
108 101
109 try_job = WfTryJob.Get(master_name, builder_name, build_number) 102 try_job = WfTryJob.Get(master_name, builder_name, build_number)
(...skipping 13 matching lines...) Expand all
123 116
124 responses = [ 117 responses = [
125 { 118 {
126 'build': { 119 'build': {
127 'id': '1', 120 'id': '1',
128 'url': 'url', 121 'url': 'url',
129 'status': 'SCHEDULED', 122 'status': 'SCHEDULED',
130 } 123 }
131 } 124 }
132 ] 125 ]
133 self._Mock_GetTrybotForWaterfallBuilder(master_name, builder_name)
134 self._Mock_TriggerTryJobs(responses) 126 self._Mock_TriggerTryJobs(responses)
135 127
136 WfTryJob.Create(master_name, builder_name, build_number).put() 128 WfTryJob.Create(master_name, builder_name, build_number).put()
137 129
138 try_job_pipeline = ScheduleTryJobPipeline() 130 try_job_pipeline = ScheduleTryJobPipeline()
139 try_job_id = try_job_pipeline.run( 131 try_job_id = try_job_pipeline.run(
140 master_name, builder_name, build_number, good_revision, bad_revision, 132 master_name, builder_name, build_number, good_revision, bad_revision,
141 TryJobType.TEST, None, targeted_tests) 133 TryJobType.TEST, None, targeted_tests)
142 134
143 try_job = WfTryJob.Get(master_name, builder_name, build_number) 135 try_job = WfTryJob.Get(master_name, builder_name, build_number)
144 self.assertEqual('1', try_job_id) 136 self.assertEqual('1', try_job_id)
145 self.assertEqual('1', try_job.test_results[-1]['try_job_id']) 137 self.assertEqual('1', try_job.test_results[-1]['try_job_id'])
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698