Re-submit node requests on ZooKeeper disconnect
Change-Id: I689bf812c713fa6f5f37958b7001b0d5fb0a254b
diff --git a/tests/test_scheduler.py b/tests/test_scheduler.py
index 64f8442..81635e0 100755
--- a/tests/test_scheduler.py
+++ b/tests/test_scheduler.py
@@ -4532,6 +4532,23 @@
self.assertEqual(A.reported, 1)
self.assertIn('RETRY_LIMIT', A.messages[0])
+ def test_zookeeper_disconnect(self):
+ "Test that jobs are launched after a zookeeper disconnect"
+
+ self.fake_nodepool.paused = True
+ A = self.fake_gerrit.addFakeChange('org/project', 'master', 'A')
+ A.addApproval('code-review', 2)
+ self.fake_gerrit.addEvent(A.addApproval('approved', 1))
+ self.waitUntilSettled()
+
+ self.zk.client.stop()
+ self.zk.client.start()
+ self.fake_nodepool.paused = False
+ self.waitUntilSettled()
+
+ self.assertEqual(A.data['status'], 'MERGED')
+ self.assertEqual(A.reported, 2)
+
class TestDuplicatePipeline(ZuulTestCase):
tenant_config_file = 'config/duplicate-pipeline/main.yaml'