Merge "Use the same default timeout for async result"
This commit is contained in:
commit
e970dd5138
|
@ -636,7 +636,7 @@ class CoordAsyncResult(object):
|
|||
"""
|
||||
|
||||
@abc.abstractmethod
|
||||
def get(self, timeout=10):
|
||||
def get(self, timeout=None):
|
||||
"""Retrieve the result of the corresponding asynchronous call.
|
||||
|
||||
:param timeout: block until the timeout expire.
|
||||
|
|
|
@ -540,7 +540,7 @@ class ZooAsyncResult(coordination.CoordAsyncResult):
|
|||
self._handler = handler
|
||||
self._kwargs = kwargs
|
||||
|
||||
def get(self, timeout=10):
|
||||
def get(self, timeout=None):
|
||||
return self._handler(self._kazoo_async_result, timeout, **self._kwargs)
|
||||
|
||||
def done(self):
|
||||
|
|
Loading…
Reference in New Issue