mirror of
https://github.com/outbackdingo/patroni.git
synced 2026-08-25 14:53:37 +00:00
@@ -197,7 +197,7 @@ class TestConsul(unittest.TestCase):
|
||||
with patch.object(KV, 'put', Mock(side_effect=ConsulException)):
|
||||
self.assertFalse(self.c.update_leader(cluster, 12345))
|
||||
mock_time = Mock(side_effect=[0, 0, 0, 0, 100, 200, 300])
|
||||
with patch('time.time', mock_time), patch('time.time_ns', mock_time):
|
||||
with patch('time.time', mock_time), patch('time.time_ns', mock_time, create=True):
|
||||
self.assertRaises(ConsulError, self.c.update_leader, cluster, 12345)
|
||||
with patch('time.time', Mock(side_effect=[0, 100, 200, 300])):
|
||||
self.assertRaises(ConsulError, self.c.update_leader, cluster, 12345)
|
||||
|
||||
@@ -442,7 +442,7 @@ class TestKubernetesEndpoints(BaseTestKubernetes):
|
||||
k8s_client.rest.ApiException(409, ''), mock_namespaced_kind()]
|
||||
mock_read.return_value.metadata.resource_version = '2'
|
||||
mock_time = Mock(side_effect=[0, 0, 100, 200, 0, 0, 0, 0, 0, 100, 200])
|
||||
with patch('time.time', mock_time), patch('time.time_ns', mock_time):
|
||||
with patch('time.time', mock_time), patch('time.time_ns', mock_time, create=True):
|
||||
self.assertFalse(self.k.update_leader(cluster, '123'))
|
||||
self.assertFalse(self.k.update_leader(cluster, '123'))
|
||||
mock_patch.side_effect = k8s_client.rest.ApiException(409, '')
|
||||
|
||||
Reference in New Issue
Block a user