diff options
author | James E. Blair <jeblair@hp.com> | 2015-05-07 14:35:34 -0700 |
---|---|---|
committer | James E. Blair <jeblair@hp.com> | 2015-05-07 14:35:34 -0700 |
commit | 1e26303bfc98645eac55230b100eb4dc6a937522 (patch) | |
tree | ddec52a4fc73a75286653cef9f275f8db21772db | |
parent | b8c16478d37f36913ea98fa37d9a2751263c1acc (diff) | |
download | zuul-1e26303bfc98645eac55230b100eb4dc6a937522.tar.gz |
Fix race in test_crd_check_duplicate
This test depends on an ordered build history, which means that we
need to control when the builds are complete (with the worker),
rather than when they start (with gearman).
Change-Id: Ib667ddf2a60a473f02d0e85f227862997e459c3d
-rwxr-xr-x | tests/test_scheduler.py | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/tests/test_scheduler.py b/tests/test_scheduler.py index 21fb04c84..d2a536b01 100755 --- a/tests/test_scheduler.py +++ b/tests/test_scheduler.py @@ -3415,7 +3415,7 @@ For CI problems and help debugging, contact ci@example.org""" def test_crd_check_duplicate(self): "Test duplicate check in independent pipelines" - self.gearman_server.hold_jobs_in_queue = True + self.worker.hold_jobs_in_build = True A = self.fake_gerrit.addFakeChange('org/project1', 'master', 'A') B = self.fake_gerrit.addFakeChange('org/project1', 'master', 'B') check_pipeline = self.sched.layout.pipelines['check'] @@ -3438,13 +3438,14 @@ For CI problems and help debugging, contact ci@example.org""" # Release jobs in order to avoid races with change A jobs # finishing before change B jobs. - self.gearman_server.release('.*-merge') - self.gearman_server.release('project1-.*') + self.worker.release('.*-merge') + self.worker.release('project1-.*') self.waitUntilSettled() - self.gearman_server.release('.*-merge') - self.gearman_server.release('project1-.*') + self.worker.release('.*-merge') + self.worker.release('project1-.*') self.waitUntilSettled() - self.gearman_server.release() + self.worker.hold_jobs_in_build = False + self.worker.release() self.waitUntilSettled() self.assertEqual(A.data['status'], 'NEW') |