Fix tests for no timeout watches.
This commit is contained in:
parent
2f2a88825d
commit
4a2295373f
1 changed files with 2 additions and 1 deletions
|
@ -124,7 +124,8 @@ class TestEphemeral(unittest.TestCase):
|
||||||
@async_test
|
@async_test
|
||||||
def test_expiring_worker(self):
|
def test_expiring_worker(self):
|
||||||
# Test that we are watching before anything else happens
|
# Test that we are watching before anything else happens
|
||||||
self.etcd_client_mock.watch.assert_called_once_with(ETCD_BUILDER_PREFIX, recursive=True)
|
self.etcd_client_mock.watch.assert_called_once_with(ETCD_BUILDER_PREFIX, recursive=True,
|
||||||
|
timeout=0)
|
||||||
|
|
||||||
# Send a signal to the callback that a worker has expired
|
# Send a signal to the callback that a worker has expired
|
||||||
expired_result = Mock(spec=etcd.EtcdResult)
|
expired_result = Mock(spec=etcd.EtcdResult)
|
||||||
|
|
Reference in a new issue