Clone repo if it is not on disk
* zuul/merger.py: Previously zuul's merger only checked an initialized
flag to determine if a repo should be cloned. If the state of the disk
changes under zuul the repo may need to be recloned even if the
initialized flag is set. Check if the repo exists on disk to determine
if the repo should be cloned to deal with external state changes. Keep
initialized flag in order to preserve ability to change git repo
settings for user and email.
* tests/test_scheduler.py: Add a test that checks a repo is recloned
when removed from the filesystem under zuul.
* tests/fixtures/layout-repo-deleted.yaml: Layout fixture for new test
added above. This creates a new repo unused by any other tests so that
failures of this test do not interfere with other tests, they will run
independent of each other.
Change-Id: I14fb34a2916002cefef73e41ec9182a073d59ef3
diff --git a/tests/test_scheduler.py b/tests/test_scheduler.py
index 70956b4..cdc6769 100644
--- a/tests/test_scheduler.py
+++ b/tests/test_scheduler.py
@@ -2807,6 +2807,43 @@
self.assertEqual(A.data['status'], 'MERGED')
self.assertEqual(A.reported, 2)
+ def test_repo_deleted(self):
+ self.config.set('zuul', 'layout_config',
+ 'tests/fixtures/layout-repo-deleted.yaml')
+ self.sched.reconfigure(self.config)
+
+ self.init_repo("org/delete-project")
+ A = self.fake_gerrit.addFakeChange('org/delete-project', 'master', 'A')
+
+ A.addApproval('CRVW', 2)
+ self.fake_gerrit.addEvent(A.addApproval('APRV', 1))
+ self.waitUntilSettled()
+ self.assertEqual(self.getJobFromHistory('project-merge').result,
+ 'SUCCESS')
+ self.assertEqual(self.getJobFromHistory('project-test1').result,
+ 'SUCCESS')
+ self.assertEqual(self.getJobFromHistory('project-test2').result,
+ 'SUCCESS')
+ self.assertEqual(A.data['status'], 'MERGED')
+ self.assertEqual(A.reported, 2)
+
+ # Delete org/new-project zuul repo. Should be recloned.
+ shutil.rmtree(os.path.join(self.git_root, "org/delete-project"))
+
+ B = self.fake_gerrit.addFakeChange('org/delete-project', 'master', 'B')
+
+ B.addApproval('CRVW', 2)
+ self.fake_gerrit.addEvent(B.addApproval('APRV', 1))
+ self.waitUntilSettled()
+ self.assertEqual(self.getJobFromHistory('project-merge').result,
+ 'SUCCESS')
+ self.assertEqual(self.getJobFromHistory('project-test1').result,
+ 'SUCCESS')
+ self.assertEqual(self.getJobFromHistory('project-test2').result,
+ 'SUCCESS')
+ self.assertEqual(B.data['status'], 'MERGED')
+ self.assertEqual(B.reported, 2)
+
def test_timer(self):
"Test that a periodic job is triggered"
self.worker.hold_jobs_in_build = True