pinecone.grpc.future 

 1from grpc._channel import _MultiThreadedRendezvous
 2from pinecone.exceptions.exceptions import PineconeException
 3
 4
 5class PineconeGrpcFuture:
 6    def __init__(self, delegate):
 7        self._delegate = delegate
 8
 9    def cancel(self):
10        return self._delegate.cancel()
11
12    def cancelled(self):
13        return self._delegate.cancelled()
14
15    def running(self):
16        return self._delegate.running()
17
18    def done(self):
19        return self._delegate.done()
20
21    def add_done_callback(self, fun):
22        return self._delegate.add_done_callback(fun)
23
24    def result(self, timeout=None):
25        try:
26            return self._delegate.result(timeout=timeout)
27        except _MultiThreadedRendezvous as e:
28            raise PineconeException(e._state.debug_error_string) from e
29
30    def exception(self, timeout=None):
31        return self._delegate.exception(timeout=timeout)
32
33    def traceback(self, timeout=None):
34        return self._delegate.traceback(timeout=timeout)
class PineconeGrpcFuture: 
 6class PineconeGrpcFuture:
 7    def __init__(self, delegate):
 8        self._delegate = delegate
 9
10    def cancel(self):
11        return self._delegate.cancel()
12
13    def cancelled(self):
14        return self._delegate.cancelled()
15
16    def running(self):
17        return self._delegate.running()
18
19    def done(self):
20        return self._delegate.done()
21
22    def add_done_callback(self, fun):
23        return self._delegate.add_done_callback(fun)
24
25    def result(self, timeout=None):
26        try:
27            return self._delegate.result(timeout=timeout)
28        except _MultiThreadedRendezvous as e:
29            raise PineconeException(e._state.debug_error_string) from e
30
31    def exception(self, timeout=None):
32        return self._delegate.exception(timeout=timeout)
33
34    def traceback(self, timeout=None):
35        return self._delegate.traceback(timeout=timeout)
PineconeGrpcFuture(delegate) 
7    def __init__(self, delegate):
8        self._delegate = delegate
def cancel(self): 
10    def cancel(self):
11        return self._delegate.cancel()
def cancelled(self): 
13    def cancelled(self):
14        return self._delegate.cancelled()
def running(self): 
16    def running(self):
17        return self._delegate.running()
def done(self): 
19    def done(self):
20        return self._delegate.done()
def add_done_callback(self, fun): 
22    def add_done_callback(self, fun):
23        return self._delegate.add_done_callback(fun)
def result(self, timeout=None): 
25    def result(self, timeout=None):
26        try:
27            return self._delegate.result(timeout=timeout)
28        except _MultiThreadedRendezvous as e:
29            raise PineconeException(e._state.debug_error_string) from e
def exception(self, timeout=None): 
31    def exception(self, timeout=None):
32        return self._delegate.exception(timeout=timeout)
def traceback(self, timeout=None): 
34    def traceback(self, timeout=None):
35        return self._delegate.traceback(timeout=timeout)