From 9af19090630765543519372e4ba6235f801ade8c Mon Sep 17 00:00:00 2001 From: hammadb Date: Fri, 26 Apr 2024 09:20:24 -0700 Subject: [PATCH] lint --- chromadb/proto/chroma_pb2_grpc.py | 208 +++++++++++++++++------------- 1 file changed, 117 insertions(+), 91 deletions(-) diff --git a/chromadb/proto/chroma_pb2_grpc.py b/chromadb/proto/chroma_pb2_grpc.py index 7a645de74452..0ad8fbb6978e 100644 --- a/chromadb/proto/chroma_pb2_grpc.py +++ b/chromadb/proto/chroma_pb2_grpc.py @@ -6,9 +6,7 @@ class MetadataReaderStub(object): - """Metadata Reader Interface - - """ + """Metadata Reader Interface""" def __init__(self, channel): """Constructor. @@ -17,65 +15,72 @@ def __init__(self, channel): channel: A grpc.Channel. """ self.QueryMetadata = channel.unary_unary( - '/chroma.MetadataReader/QueryMetadata', - request_serializer=chromadb_dot_proto_dot_chroma__pb2.QueryMetadataRequest.SerializeToString, - response_deserializer=chromadb_dot_proto_dot_chroma__pb2.QueryMetadataResponse.FromString, - ) + "/chroma.MetadataReader/QueryMetadata", + request_serializer=chromadb_dot_proto_dot_chroma__pb2.QueryMetadataRequest.SerializeToString, + response_deserializer=chromadb_dot_proto_dot_chroma__pb2.QueryMetadataResponse.FromString, + ) class MetadataReaderServicer(object): - """Metadata Reader Interface - - """ + """Metadata Reader Interface""" def QueryMetadata(self, request, context): """Missing associated documentation comment in .proto file.""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def add_MetadataReaderServicer_to_server(servicer, server): rpc_method_handlers = { - 'QueryMetadata': grpc.unary_unary_rpc_method_handler( - servicer.QueryMetadata, - request_deserializer=chromadb_dot_proto_dot_chroma__pb2.QueryMetadataRequest.FromString, - response_serializer=chromadb_dot_proto_dot_chroma__pb2.QueryMetadataResponse.SerializeToString, - ), + "QueryMetadata": grpc.unary_unary_rpc_method_handler( + servicer.QueryMetadata, + request_deserializer=chromadb_dot_proto_dot_chroma__pb2.QueryMetadataRequest.FromString, + response_serializer=chromadb_dot_proto_dot_chroma__pb2.QueryMetadataResponse.SerializeToString, + ), } generic_handler = grpc.method_handlers_generic_handler( - 'chroma.MetadataReader', rpc_method_handlers) + "chroma.MetadataReader", rpc_method_handlers + ) server.add_generic_rpc_handlers((generic_handler,)) - # This class is part of an EXPERIMENTAL API. +# This class is part of an EXPERIMENTAL API. class MetadataReader(object): - """Metadata Reader Interface - - """ + """Metadata Reader Interface""" @staticmethod - def QueryMetadata(request, + def QueryMetadata( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/chroma.MetadataReader/QueryMetadata', + "/chroma.MetadataReader/QueryMetadata", chromadb_dot_proto_dot_chroma__pb2.QueryMetadataRequest.SerializeToString, chromadb_dot_proto_dot_chroma__pb2.QueryMetadataResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) class VectorReaderStub(object): - """Vector Reader Interface - - """ + """Vector Reader Interface""" def __init__(self, channel): """Constructor. @@ -84,89 +89,110 @@ def __init__(self, channel): channel: A grpc.Channel. """ self.GetVectors = channel.unary_unary( - '/chroma.VectorReader/GetVectors', - request_serializer=chromadb_dot_proto_dot_chroma__pb2.GetVectorsRequest.SerializeToString, - response_deserializer=chromadb_dot_proto_dot_chroma__pb2.GetVectorsResponse.FromString, - ) + "/chroma.VectorReader/GetVectors", + request_serializer=chromadb_dot_proto_dot_chroma__pb2.GetVectorsRequest.SerializeToString, + response_deserializer=chromadb_dot_proto_dot_chroma__pb2.GetVectorsResponse.FromString, + ) self.QueryVectors = channel.unary_unary( - '/chroma.VectorReader/QueryVectors', - request_serializer=chromadb_dot_proto_dot_chroma__pb2.QueryVectorsRequest.SerializeToString, - response_deserializer=chromadb_dot_proto_dot_chroma__pb2.QueryVectorsResponse.FromString, - ) + "/chroma.VectorReader/QueryVectors", + request_serializer=chromadb_dot_proto_dot_chroma__pb2.QueryVectorsRequest.SerializeToString, + response_deserializer=chromadb_dot_proto_dot_chroma__pb2.QueryVectorsResponse.FromString, + ) class VectorReaderServicer(object): - """Vector Reader Interface - - """ + """Vector Reader Interface""" def GetVectors(self, request, context): """Missing associated documentation comment in .proto file.""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def QueryVectors(self, request, context): """Missing associated documentation comment in .proto file.""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def add_VectorReaderServicer_to_server(servicer, server): rpc_method_handlers = { - 'GetVectors': grpc.unary_unary_rpc_method_handler( - servicer.GetVectors, - request_deserializer=chromadb_dot_proto_dot_chroma__pb2.GetVectorsRequest.FromString, - response_serializer=chromadb_dot_proto_dot_chroma__pb2.GetVectorsResponse.SerializeToString, - ), - 'QueryVectors': grpc.unary_unary_rpc_method_handler( - servicer.QueryVectors, - request_deserializer=chromadb_dot_proto_dot_chroma__pb2.QueryVectorsRequest.FromString, - response_serializer=chromadb_dot_proto_dot_chroma__pb2.QueryVectorsResponse.SerializeToString, - ), + "GetVectors": grpc.unary_unary_rpc_method_handler( + servicer.GetVectors, + request_deserializer=chromadb_dot_proto_dot_chroma__pb2.GetVectorsRequest.FromString, + response_serializer=chromadb_dot_proto_dot_chroma__pb2.GetVectorsResponse.SerializeToString, + ), + "QueryVectors": grpc.unary_unary_rpc_method_handler( + servicer.QueryVectors, + request_deserializer=chromadb_dot_proto_dot_chroma__pb2.QueryVectorsRequest.FromString, + response_serializer=chromadb_dot_proto_dot_chroma__pb2.QueryVectorsResponse.SerializeToString, + ), } generic_handler = grpc.method_handlers_generic_handler( - 'chroma.VectorReader', rpc_method_handlers) + "chroma.VectorReader", rpc_method_handlers + ) server.add_generic_rpc_handlers((generic_handler,)) - # This class is part of an EXPERIMENTAL API. +# This class is part of an EXPERIMENTAL API. class VectorReader(object): - """Vector Reader Interface - - """ + """Vector Reader Interface""" @staticmethod - def GetVectors(request, + def GetVectors( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/chroma.VectorReader/GetVectors', + "/chroma.VectorReader/GetVectors", chromadb_dot_proto_dot_chroma__pb2.GetVectorsRequest.SerializeToString, chromadb_dot_proto_dot_chroma__pb2.GetVectorsResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) @staticmethod - def QueryVectors(request, + def QueryVectors( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/chroma.VectorReader/QueryVectors', + "/chroma.VectorReader/QueryVectors", chromadb_dot_proto_dot_chroma__pb2.QueryVectorsRequest.SerializeToString, chromadb_dot_proto_dot_chroma__pb2.QueryVectorsResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + )