|
7 | 7 | from typing import NamedTuple, Optional, Dict |
8 | 8 |
|
9 | 9 | import grpc |
| 10 | +import certifi |
10 | 11 |
|
11 | 12 | from pinecone import logger |
12 | 13 | from pinecone.config import Config |
@@ -96,7 +97,8 @@ def _gen_channel(self, options=None): |
96 | 97 | if not self.grpc_client_config.secure: |
97 | 98 | channel = grpc.insecure_channel(target, options=_options) |
98 | 99 | else: |
99 | | - tls = grpc.ssl_channel_credentials() |
| 100 | + root_cas = open(certifi.where(), "rb").read() |
| 101 | + tls = grpc.ssl_channel_credentials(root_certificates=root_cas) |
100 | 102 | channel = grpc.secure_channel(target, tls, options=_options) |
101 | 103 | interceptor = RetryOnRpcErrorClientInterceptor(self.retry_config) |
102 | 104 | return grpc.intercept_channel(channel, interceptor) |
@@ -182,11 +184,11 @@ def query(self, |
182 | 184 | metadata: Dict[str, str] = None): |
183 | 185 | return self._wrap_grpc_call(self.stub.Query, request, timeout=timeout, metadata=metadata) |
184 | 186 |
|
185 | | - def summarize(self, |
186 | | - request: 'vector_service_pb2.SummarizeRequest', |
| 187 | + def describe_index_stats(self, |
| 188 | + request: 'vector_service_pb2.DescribeIndexStatsRequest', |
187 | 189 | timeout: int = None, |
188 | 190 | metadata: Dict[str, str] = None): |
189 | | - return self._wrap_grpc_call(self.stub.Summarize, request, timeout=timeout, metadata=metadata) |
| 191 | + return self._wrap_grpc_call(self.stub.DescribeIndexStats, request, timeout=timeout, metadata=metadata) |
190 | 192 |
|
191 | 193 |
|
192 | 194 | class CIndex(GRPCIndex): |
@@ -219,10 +221,10 @@ def query(self, |
219 | 221 | metadata: Dict[str, str] = None): |
220 | 222 | return self._wrap_grpc_call(self.stub.Query, request, timeout=timeout, metadata=metadata) |
221 | 223 |
|
222 | | - def summarize(self, |
223 | | - request: 'vector_column_service_pb2.SummarizeRequest', |
| 224 | + def describe_index_stats(self, |
| 225 | + request: 'vector_column_service_pb2.DescribeIndexStatsRequest', |
224 | 226 | timeout: int = None, |
225 | 227 | metadata: Dict[str, str] = None): |
226 | | - return self._wrap_grpc_call(self.stub.Summarize, request, timeout=timeout, metadata=metadata) |
| 228 | + return self._wrap_grpc_call(self.stub.DescribeIndexStats, request, timeout=timeout, metadata=metadata) |
227 | 229 |
|
228 | 230 |
|
0 commit comments