Skip to content

Commit 320cebe

Browse files
authored
Merge pull request #5 from pinecone-io/ch9713
Changing summarize function name and certs issue with grpc client
2 parents c58b20c + f620b0e commit 320cebe

File tree

1 file changed

+9
-7
lines changed

1 file changed

+9
-7
lines changed

pinecone/core/grpc/index_grpc.py

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@
77
from typing import NamedTuple, Optional, Dict
88

99
import grpc
10+
import certifi
1011

1112
from pinecone.config import Config
1213
from pinecone.core.grpc.protos.vector_column_service_pb2_grpc import VectorColumnServiceStub
@@ -98,7 +99,8 @@ def _gen_channel(self, options=None):
9899
if not self.grpc_client_config.secure:
99100
channel = grpc.insecure_channel(target, options=_options)
100101
else:
101-
tls = grpc.ssl_channel_credentials()
102+
root_cas = open(certifi.where(), "rb").read()
103+
tls = grpc.ssl_channel_credentials(root_certificates=root_cas)
102104
channel = grpc.secure_channel(target, tls, options=_options)
103105
interceptor = RetryOnRpcErrorClientInterceptor(self.retry_config)
104106
return grpc.intercept_channel(channel, interceptor)
@@ -184,11 +186,11 @@ def query(self,
184186
metadata: Dict[str, str] = None):
185187
return self._wrap_grpc_call(self.stub.Query, request, timeout=timeout, metadata=metadata)
186188

187-
def summarize(self,
188-
request: 'vector_service_pb2.SummarizeRequest',
189+
def describe_index_stats(self,
190+
request: 'vector_service_pb2.DescribeIndexStatsRequest',
189191
timeout: int = None,
190192
metadata: Dict[str, str] = None):
191-
return self._wrap_grpc_call(self.stub.Summarize, request, timeout=timeout, metadata=metadata)
193+
return self._wrap_grpc_call(self.stub.DescribeIndexStats, request, timeout=timeout, metadata=metadata)
192194

193195

194196
class CIndex(GRPCIndex):
@@ -221,10 +223,10 @@ def query(self,
221223
metadata: Dict[str, str] = None):
222224
return self._wrap_grpc_call(self.stub.Query, request, timeout=timeout, metadata=metadata)
223225

224-
def summarize(self,
225-
request: 'vector_column_service_pb2.SummarizeRequest',
226+
def describe_index_stats(self,
227+
request: 'vector_column_service_pb2.DescribeIndexStatsRequest',
226228
timeout: int = None,
227229
metadata: Dict[str, str] = None):
228-
return self._wrap_grpc_call(self.stub.Summarize, request, timeout=timeout, metadata=metadata)
230+
return self._wrap_grpc_call(self.stub.DescribeIndexStats, request, timeout=timeout, metadata=metadata)
229231

230232

0 commit comments

Comments
 (0)