diff --git a/README.md b/README.md index b0f4a92..e7cfa4d 100644 --- a/README.md +++ b/README.md @@ -1,6 +1,6 @@ # e6data Python Connector -![version](https://img.shields.io/badge/version-2.2.2-blue.svg) +![version](https://img.shields.io/badge/version-2.2.3.rc1-blue.svg) ## Introduction diff --git a/e6data_python_connector/e6data_grpc.py b/e6data_python_connector/e6data_grpc.py index ddb7eb9..cb6171b 100644 --- a/e6data_python_connector/e6data_grpc.py +++ b/e6data_python_connector/e6data_grpc.py @@ -71,12 +71,8 @@ def wrapper(self, *args, **kwargs): try: return func(self, *args, **kwargs) except _InactiveRpcError as e: - print(f'RE_AUTH: Function Name: {func}') - print(f'RE_AUTH: Error Found {e}') if e.code() == grpc.StatusCode.INTERNAL and 'Access denied' in e.details(): - print('RE_AUTH: Initialising re-authentication.') self.connection.get_re_authenticate_session_id() - print(f'RE_AUTH: Re-auth successful.') return func(self, *args, **kwargs) else: raise e @@ -192,6 +188,7 @@ def __init__( self._max_receive_message_length = -1 self._max_send_message_length = 300 * 1024 * 1024 # mb self.grpc_prepare_timeout = 10 * 60 # 10 minutes + self._planner_ip = None if isinstance(grpc_options, dict): self._keepalive_timeout_ms = grpc_options.get('keepalive_timeout_ms') or self._keepalive_timeout_ms @@ -224,7 +221,8 @@ def _create_client(self): self._client = e6x_engine_pb2_grpc.QueryEngineServiceStub(self._channel) def get_re_authenticate_session_id(self): - self._session_id = None + self.close() + self._create_client() return self.get_session_id @property @@ -243,6 +241,7 @@ def get_session_id(self): metadata=_get_grpc_header(cluster=self.cluster_uuid) ) self._session_id = authenticate_response.sessionId + self._planner_ip = authenticate_response.plannerIp if not self._session_id: raise ValueError("Invalid credentials.") except _InactiveRpcError as e: @@ -266,6 +265,7 @@ def get_session_id(self): metadata=_get_grpc_header(cluster=self.cluster_uuid) ) self._session_id = authenticate_response.sessionId + self._planner_ip = authenticate_response.plannerIp else: raise e else: @@ -423,6 +423,8 @@ def _reset_state(self): @property def metadata(self): + if not self._engine_ip: + self._engine_ip = self.connection._planner_ip return _get_grpc_header(engine_ip=self._engine_ip, cluster=self.connection.cluster_uuid) @property @@ -568,7 +570,8 @@ def execute(self, operation, parameters=None, **kwargs): sessionId=self.connection.get_session_id, schema=self._database, catalog=self._catalog_name, - queryString=sql + queryString=sql, + plannerIp=self._engine_ip ) prepare_statement_response = client.prepareStatementV2( prepare_statement_request, diff --git a/e6data_python_connector/server/e6x_engine_pb2.py b/e6data_python_connector/server/e6x_engine_pb2.py index 756dbd5..c29ebce 100644 --- a/e6data_python_connector/server/e6x_engine_pb2.py +++ b/e6data_python_connector/server/e6x_engine_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: e6x_engine.proto +# Protobuf Python Version: 5.26.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -13,14 +14,14 @@ -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x10\x65\x36x_engine.proto\"2\n\nGFieldInfo\x12\x11\n\tfieldName\x18\x01 \x01(\t\x12\x11\n\tfieldType\x18\x02 \x01(\t\"A\n\x13\x46\x61iledSchemaElement\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0c\n\x04type\x18\x02 \x01(\t\x12\x0e\n\x06reason\x18\x03 \x01(\t\"P\n\x16GetAddCatalogsResponse\x12\x0e\n\x06status\x18\x01 \x01(\t\x12&\n\x08\x66\x61ilures\x18\x02 \x03(\x0b\x32\x14.FailedSchemaElement\"2\n\x0f\x43\x61talogResponse\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x11\n\tisDefault\x18\x02 \x01(\x08\"<\n\x0eParameterValue\x12\r\n\x05index\x18\x01 \x01(\x11\x12\x0c\n\x04type\x18\x02 \x01(\t\x12\r\n\x05value\x18\x03 \x01(\t\"D\n\x0c\x43learRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\"\x0f\n\rClearResponse\"J\n\x12\x43\x61ncelQueryRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\"\x15\n\x13\x43\x61ncelQueryResponse\"F\n\x0e\x45xplainRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\"\"\n\x0f\x45xplainResponse\x12\x0f\n\x07\x65xplain\x18\x01 \x01(\t\"Y\n\rDryRunRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0e\n\x06schema\x18\x03 \x01(\t\x12\x13\n\x0bqueryString\x18\x04 \x01(\t\"%\n\x0e\x44ryRunResponse\x12\x13\n\x0b\x64ryrunValue\x18\x01 \x01(\t\"l\n\x0f\x44ryRunRequestV2\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0e\n\x06schema\x18\x03 \x01(\t\x12\x13\n\x0bqueryString\x18\x04 \x01(\t\x12\x0f\n\x07\x63\x61talog\x18\x05 \x01(\t\"M\n\x15\x45xplainAnalyzeRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\"m\n\x16\x45xplainAnalyzeResponse\x12\x16\n\x0e\x65xplainAnalyze\x18\x01 \x01(\t\x12\x10\n\x08isCached\x18\x02 \x01(\x08\x12\x13\n\x0bparsingTime\x18\x03 \x01(\x12\x12\x14\n\x0cqueueingTime\x18\x04 \x01(\x12\"b\n\x17PrepareStatementRequest\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\x0e\n\x06schema\x18\x02 \x01(\t\x12\x13\n\x0bqueryString\x18\x03 \x01(\t\x12\x0f\n\x07quoting\x18\x04 \x01(\t\"u\n\x19PrepareStatementV2Request\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\x0e\n\x06schema\x18\x02 \x01(\t\x12\x0f\n\x07\x63\x61talog\x18\x03 \x01(\t\x12\x13\n\x0bqueryString\x18\x04 \x01(\t\x12\x0f\n\x07quoting\x18\x05 \x01(\t\"=\n\x18PrepareStatementResponse\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x0f\n\x07queryId\x18\x02 \x01(\t\"@\n\x0eUserAccessInfo\x12\x0c\n\x04uuid\x18\x01 \x01(\t\x12\x10\n\x08userName\x18\x02 \x01(\t\x12\x0e\n\x06tokens\x18\x03 \x03(\t\"g\n\x17\x45xecuteStatementRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\x12\x16\n\x0eshouldNotCache\x18\x04 \x01(\x08\"\x8a\x01\n\x19\x45xecuteStatementV2Request\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\x12\x16\n\x0eshouldNotCache\x18\x04 \x01(\x08\x12\x1f\n\x06params\x18\x05 \x03(\x0b\x32\x0f.ParameterValue\"\x1a\n\x18\x45xecuteStatementResponse\"O\n\x17GetNextResultRowRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\"-\n\x18GetNextResultRowResponse\x12\x11\n\tresultRow\x18\x02 \x01(\x0c\"w\n\x19GetNextResultBatchRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\x12\x16\n\tasRowData\x18\x04 \x01(\x08H\x00\x88\x01\x01\x42\x0c\n\n_asRowData\"1\n\x1aGetNextResultBatchResponse\x12\x13\n\x0bresultBatch\x18\x02 \x01(\x0c\"P\n\x18GetResultMetadataRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\"3\n\x19GetResultMetadataResponse\x12\x16\n\x0eresultMetaData\x18\x01 \x01(\x0c\"5\n\x13\x41uthenticateRequest\x12\x0c\n\x04user\x18\x01 \x01(\t\x12\x10\n\x08password\x18\x02 \x01(\t\")\n\x14\x41uthenticateResponse\x12\x11\n\tsessionId\x18\x01 \x01(\t\"5\n\x10GetTablesRequest\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\x0e\n\x06schema\x18\x02 \x01(\t\"H\n\x12GetTablesV2Request\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\x0e\n\x06schema\x18\x02 \x01(\t\x12\x0f\n\x07\x63\x61talog\x18\x03 \x01(\t\"#\n\x11GetTablesResponse\x12\x0e\n\x06tables\x18\x01 \x03(\t\"*\n\x15GetSchemaNamesRequest\x12\x11\n\tsessionId\x18\x01 \x01(\t\"=\n\x17GetSchemaNamesV2Request\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\x0f\n\x07\x63\x61talog\x18\x02 \x01(\t\")\n\x16GetSchemaNamesResponse\x12\x0f\n\x07schemas\x18\x01 \x03(\t\"E\n\x11GetColumnsRequest\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\x0e\n\x06schema\x18\x02 \x01(\t\x12\r\n\x05table\x18\x03 \x01(\t\"X\n\x13GetColumnsV2Request\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\x0e\n\x06schema\x18\x02 \x01(\t\x12\r\n\x05table\x18\x03 \x01(\t\x12\x0f\n\x07\x63\x61talog\x18\x04 \x01(\t\"4\n\x12GetColumnsResponse\x12\x1e\n\tfieldInfo\x18\x01 \x03(\x0b\x32\x0b.GFieldInfo\"E\n\rStatusRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\"2\n\x0eStatusResponse\x12\x0e\n\x06status\x18\x02 \x01(\x08\x12\x10\n\x08rowCount\x18\x03 \x01(\x12\"5\n\x12\x41\x64\x64\x43\x61talogsRequest\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\x0c\n\x04json\x18\x02 \x01(\t\"#\n\x12UpdateUsersRequest\x12\r\n\x05users\x18\x01 \x01(\x0c\"\x15\n\x13UpdateUsersResponse\"3\n\x0fSetPropsRequest\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\r\n\x05props\x18\x02 \x01(\t\"\x12\n\x10SetPropsResponse\"*\n\x15GetAddCatalogsRequest\x12\x11\n\tsessionId\x18\x01 \x01(\t\"\x15\n\x13\x41\x64\x64\x43\x61talogsResponse\"\x15\n\x13GetCatalogesRequest\"B\n\x14GetCatalogesResponse\x12*\n\x10\x63\x61talogResponses\x18\x01 \x03(\x0b\x32\x10.CatalogResponse\"+\n\x16RefreshCatalogsRequest\x12\x11\n\tsessionId\x18\x01 \x01(\t\"\x19\n\x17RefreshCatalogsResponse\"X\n\x12RemoteChunkRequest\x12\x17\n\x0foriginalQueryId\x18\x01 \x01(\t\x12\x15\n\rremoteQueryId\x18\x02 \x01(\t\x12\x12\n\nsQueryHash\x18\x03 \x01(\t\"3\n\x13RemoteChunkResponse\x12\r\n\x05\x65rror\x18\x01 \x01(\t\x12\r\n\x05\x63hunk\x18\x02 \x01(\x0c\"Q\n\x19\x43learOrCancelQueryRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\"\x1c\n\x1a\x43learOrCancelQueryResponse2\xaa\x0e\n\x12QueryEngineService\x12&\n\x05\x63lear\x12\r.ClearRequest\x1a\x0e.ClearResponse\x12\x38\n\x0b\x63\x61ncelQuery\x12\x13.CancelQueryRequest\x1a\x14.CancelQueryResponse\x12M\n\x12\x63learOrCancelQuery\x12\x1a.ClearOrCancelQueryRequest\x1a\x1b.ClearOrCancelQueryResponse\x12,\n\x07\x65xplain\x12\x0f.ExplainRequest\x1a\x10.ExplainResponse\x12)\n\x06\x64ryRun\x12\x0e.DryRunRequest\x1a\x0f.DryRunResponse\x12-\n\x08\x64ryRunV2\x12\x10.DryRunRequestV2\x1a\x0f.DryRunResponse\x12\x41\n\x0e\x65xplainAnalyze\x12\x16.ExplainAnalyzeRequest\x1a\x17.ExplainAnalyzeResponse\x12G\n\x10prepareStatement\x12\x18.PrepareStatementRequest\x1a\x19.PrepareStatementResponse\x12K\n\x12prepareStatementV2\x12\x1a.PrepareStatementV2Request\x1a\x19.PrepareStatementResponse\x12G\n\x10\x65xecuteStatement\x12\x18.ExecuteStatementRequest\x1a\x19.ExecuteStatementResponse\x12K\n\x12\x65xecuteStatementV2\x12\x1a.ExecuteStatementV2Request\x1a\x19.ExecuteStatementResponse\x12G\n\x10getNextResultRow\x12\x18.GetNextResultRowRequest\x1a\x19.GetNextResultRowResponse\x12M\n\x12getNextResultBatch\x12\x1a.GetNextResultBatchRequest\x1a\x1b.GetNextResultBatchResponse\x12J\n\x11getResultMetadata\x12\x19.GetResultMetadataRequest\x1a\x1a.GetResultMetadataResponse\x12;\n\x0c\x61uthenticate\x12\x14.AuthenticateRequest\x1a\x15.AuthenticateResponse\x12\x32\n\tgetTables\x12\x11.GetTablesRequest\x1a\x12.GetTablesResponse\x12\x36\n\x0bgetTablesV2\x12\x13.GetTablesV2Request\x1a\x12.GetTablesResponse\x12\x41\n\x0egetSchemaNames\x12\x16.GetSchemaNamesRequest\x1a\x17.GetSchemaNamesResponse\x12\x45\n\x10getSchemaNamesV2\x12\x18.GetSchemaNamesV2Request\x1a\x17.GetSchemaNamesResponse\x12\x35\n\ngetColumns\x12\x12.GetColumnsRequest\x1a\x13.GetColumnsResponse\x12\x39\n\x0cgetColumnsV2\x12\x14.GetColumnsV2Request\x1a\x13.GetColumnsResponse\x12\x38\n\x0bupdateUsers\x12\x13.UpdateUsersRequest\x1a\x14.UpdateUsersResponse\x12/\n\x08setProps\x12\x10.SetPropsRequest\x1a\x11.SetPropsResponse\x12)\n\x06status\x12\x0e.StatusRequest\x1a\x0f.StatusResponse\x12\x38\n\x0b\x61\x64\x64\x43\x61talogs\x12\x13.AddCatalogsRequest\x1a\x14.AddCatalogsResponse\x12I\n\x16getAddCatalogsResponse\x12\x16.GetAddCatalogsRequest\x1a\x17.GetAddCatalogsResponse\x12;\n\x0cgetCataloges\x12\x14.GetCatalogesRequest\x1a\x15.GetCatalogesResponse\x12\x45\n\x18getNextRemoteCachedChunk\x12\x13.RemoteChunkRequest\x1a\x14.RemoteChunkResponse\x12\x44\n\x0frefreshCatalogs\x12\x17.RefreshCatalogsRequest\x1a\x18.RefreshCatalogsResponseB\x02P\x01\x62\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x10\x65\x36x_engine.proto\"2\n\nGFieldInfo\x12\x11\n\tfieldName\x18\x01 \x01(\t\x12\x11\n\tfieldType\x18\x02 \x01(\t\"A\n\x13\x46\x61iledSchemaElement\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0c\n\x04type\x18\x02 \x01(\t\x12\x0e\n\x06reason\x18\x03 \x01(\t\"P\n\x16GetAddCatalogsResponse\x12\x0e\n\x06status\x18\x01 \x01(\t\x12&\n\x08\x66\x61ilures\x18\x02 \x03(\x0b\x32\x14.FailedSchemaElement\"2\n\x0f\x43\x61talogResponse\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x11\n\tisDefault\x18\x02 \x01(\x08\"<\n\x0eParameterValue\x12\r\n\x05index\x18\x01 \x01(\x11\x12\x0c\n\x04type\x18\x02 \x01(\t\x12\r\n\x05value\x18\x03 \x01(\t\"D\n\x0c\x43learRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\"\x0f\n\rClearResponse\"J\n\x12\x43\x61ncelQueryRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\"\x15\n\x13\x43\x61ncelQueryResponse\"F\n\x0e\x45xplainRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\"\"\n\x0f\x45xplainResponse\x12\x0f\n\x07\x65xplain\x18\x01 \x01(\t\"Y\n\rDryRunRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0e\n\x06schema\x18\x03 \x01(\t\x12\x13\n\x0bqueryString\x18\x04 \x01(\t\"%\n\x0e\x44ryRunResponse\x12\x13\n\x0b\x64ryrunValue\x18\x01 \x01(\t\"l\n\x0f\x44ryRunRequestV2\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0e\n\x06schema\x18\x03 \x01(\t\x12\x13\n\x0bqueryString\x18\x04 \x01(\t\x12\x0f\n\x07\x63\x61talog\x18\x05 \x01(\t\"M\n\x15\x45xplainAnalyzeRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\"m\n\x16\x45xplainAnalyzeResponse\x12\x16\n\x0e\x65xplainAnalyze\x18\x01 \x01(\t\x12\x10\n\x08isCached\x18\x02 \x01(\x08\x12\x13\n\x0bparsingTime\x18\x03 \x01(\x12\x12\x14\n\x0cqueueingTime\x18\x04 \x01(\x12\"b\n\x17PrepareStatementRequest\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\x0e\n\x06schema\x18\x02 \x01(\t\x12\x13\n\x0bqueryString\x18\x03 \x01(\t\x12\x0f\n\x07quoting\x18\x04 \x01(\t\"\x9b\x01\n\x19PrepareStatementV2Request\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\x0e\n\x06schema\x18\x02 \x01(\t\x12\x0f\n\x07\x63\x61talog\x18\x03 \x01(\t\x12\x13\n\x0bqueryString\x18\x04 \x01(\t\x12\x0f\n\x07quoting\x18\x05 \x01(\t\x12\x16\n\tplannerIp\x18\x06 \x01(\tH\x00\x88\x01\x01\x42\x0c\n\n_plannerIp\"=\n\x18PrepareStatementResponse\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x0f\n\x07queryId\x18\x02 \x01(\t\"@\n\x0eUserAccessInfo\x12\x0c\n\x04uuid\x18\x01 \x01(\t\x12\x10\n\x08userName\x18\x02 \x01(\t\x12\x0e\n\x06tokens\x18\x03 \x03(\t\"g\n\x17\x45xecuteStatementRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\x12\x16\n\x0eshouldNotCache\x18\x04 \x01(\x08\"\x8a\x01\n\x19\x45xecuteStatementV2Request\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\x12\x16\n\x0eshouldNotCache\x18\x04 \x01(\x08\x12\x1f\n\x06params\x18\x05 \x03(\x0b\x32\x0f.ParameterValue\"\x1a\n\x18\x45xecuteStatementResponse\"O\n\x17GetNextResultRowRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\"-\n\x18GetNextResultRowResponse\x12\x11\n\tresultRow\x18\x02 \x01(\x0c\"w\n\x19GetNextResultBatchRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\x12\x16\n\tasRowData\x18\x04 \x01(\x08H\x00\x88\x01\x01\x42\x0c\n\n_asRowData\"1\n\x1aGetNextResultBatchResponse\x12\x13\n\x0bresultBatch\x18\x02 \x01(\x0c\"P\n\x18GetResultMetadataRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\"3\n\x19GetResultMetadataResponse\x12\x16\n\x0eresultMetaData\x18\x01 \x01(\x0c\"5\n\x13\x41uthenticateRequest\x12\x0c\n\x04user\x18\x01 \x01(\t\x12\x10\n\x08password\x18\x02 \x01(\t\"<\n\x14\x41uthenticateResponse\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\x11\n\tplannerIp\x18\x02 \x01(\t\"5\n\x10GetTablesRequest\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\x0e\n\x06schema\x18\x02 \x01(\t\"H\n\x12GetTablesV2Request\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\x0e\n\x06schema\x18\x02 \x01(\t\x12\x0f\n\x07\x63\x61talog\x18\x03 \x01(\t\"#\n\x11GetTablesResponse\x12\x0e\n\x06tables\x18\x01 \x03(\t\"*\n\x15GetSchemaNamesRequest\x12\x11\n\tsessionId\x18\x01 \x01(\t\"=\n\x17GetSchemaNamesV2Request\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\x0f\n\x07\x63\x61talog\x18\x02 \x01(\t\")\n\x16GetSchemaNamesResponse\x12\x0f\n\x07schemas\x18\x01 \x03(\t\"E\n\x11GetColumnsRequest\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\x0e\n\x06schema\x18\x02 \x01(\t\x12\r\n\x05table\x18\x03 \x01(\t\"X\n\x13GetColumnsV2Request\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\x0e\n\x06schema\x18\x02 \x01(\t\x12\r\n\x05table\x18\x03 \x01(\t\x12\x0f\n\x07\x63\x61talog\x18\x04 \x01(\t\"4\n\x12GetColumnsResponse\x12\x1e\n\tfieldInfo\x18\x01 \x03(\x0b\x32\x0b.GFieldInfo\"E\n\rStatusRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\"2\n\x0eStatusResponse\x12\x0e\n\x06status\x18\x02 \x01(\x08\x12\x10\n\x08rowCount\x18\x03 \x01(\x12\"5\n\x12\x41\x64\x64\x43\x61talogsRequest\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\x0c\n\x04json\x18\x02 \x01(\t\"#\n\x12UpdateUsersRequest\x12\r\n\x05users\x18\x01 \x01(\x0c\"\x15\n\x13UpdateUsersResponse\"3\n\x0fSetPropsRequest\x12\x11\n\tsessionId\x18\x01 \x01(\t\x12\r\n\x05props\x18\x02 \x01(\t\"\x12\n\x10SetPropsResponse\"*\n\x15GetAddCatalogsRequest\x12\x11\n\tsessionId\x18\x01 \x01(\t\"\x15\n\x13\x41\x64\x64\x43\x61talogsResponse\"\x15\n\x13GetCatalogesRequest\"B\n\x14GetCatalogesResponse\x12*\n\x10\x63\x61talogResponses\x18\x01 \x03(\x0b\x32\x10.CatalogResponse\"+\n\x16RefreshCatalogsRequest\x12\x11\n\tsessionId\x18\x01 \x01(\t\"\x19\n\x17RefreshCatalogsResponse\"X\n\x12RemoteChunkRequest\x12\x17\n\x0foriginalQueryId\x18\x01 \x01(\t\x12\x15\n\rremoteQueryId\x18\x02 \x01(\t\x12\x12\n\nsQueryHash\x18\x03 \x01(\t\"3\n\x13RemoteChunkResponse\x12\r\n\x05\x65rror\x18\x01 \x01(\t\x12\r\n\x05\x63hunk\x18\x02 \x01(\x0c\"Q\n\x19\x43learOrCancelQueryRequest\x12\x10\n\x08\x65ngineIP\x18\x01 \x01(\t\x12\x11\n\tsessionId\x18\x02 \x01(\t\x12\x0f\n\x07queryId\x18\x03 \x01(\t\"\x1c\n\x1a\x43learOrCancelQueryResponse2\xaa\x0e\n\x12QueryEngineService\x12&\n\x05\x63lear\x12\r.ClearRequest\x1a\x0e.ClearResponse\x12\x38\n\x0b\x63\x61ncelQuery\x12\x13.CancelQueryRequest\x1a\x14.CancelQueryResponse\x12M\n\x12\x63learOrCancelQuery\x12\x1a.ClearOrCancelQueryRequest\x1a\x1b.ClearOrCancelQueryResponse\x12,\n\x07\x65xplain\x12\x0f.ExplainRequest\x1a\x10.ExplainResponse\x12)\n\x06\x64ryRun\x12\x0e.DryRunRequest\x1a\x0f.DryRunResponse\x12-\n\x08\x64ryRunV2\x12\x10.DryRunRequestV2\x1a\x0f.DryRunResponse\x12\x41\n\x0e\x65xplainAnalyze\x12\x16.ExplainAnalyzeRequest\x1a\x17.ExplainAnalyzeResponse\x12G\n\x10prepareStatement\x12\x18.PrepareStatementRequest\x1a\x19.PrepareStatementResponse\x12K\n\x12prepareStatementV2\x12\x1a.PrepareStatementV2Request\x1a\x19.PrepareStatementResponse\x12G\n\x10\x65xecuteStatement\x12\x18.ExecuteStatementRequest\x1a\x19.ExecuteStatementResponse\x12K\n\x12\x65xecuteStatementV2\x12\x1a.ExecuteStatementV2Request\x1a\x19.ExecuteStatementResponse\x12G\n\x10getNextResultRow\x12\x18.GetNextResultRowRequest\x1a\x19.GetNextResultRowResponse\x12M\n\x12getNextResultBatch\x12\x1a.GetNextResultBatchRequest\x1a\x1b.GetNextResultBatchResponse\x12J\n\x11getResultMetadata\x12\x19.GetResultMetadataRequest\x1a\x1a.GetResultMetadataResponse\x12;\n\x0c\x61uthenticate\x12\x14.AuthenticateRequest\x1a\x15.AuthenticateResponse\x12\x32\n\tgetTables\x12\x11.GetTablesRequest\x1a\x12.GetTablesResponse\x12\x36\n\x0bgetTablesV2\x12\x13.GetTablesV2Request\x1a\x12.GetTablesResponse\x12\x41\n\x0egetSchemaNames\x12\x16.GetSchemaNamesRequest\x1a\x17.GetSchemaNamesResponse\x12\x45\n\x10getSchemaNamesV2\x12\x18.GetSchemaNamesV2Request\x1a\x17.GetSchemaNamesResponse\x12\x35\n\ngetColumns\x12\x12.GetColumnsRequest\x1a\x13.GetColumnsResponse\x12\x39\n\x0cgetColumnsV2\x12\x14.GetColumnsV2Request\x1a\x13.GetColumnsResponse\x12\x38\n\x0bupdateUsers\x12\x13.UpdateUsersRequest\x1a\x14.UpdateUsersResponse\x12/\n\x08setProps\x12\x10.SetPropsRequest\x1a\x11.SetPropsResponse\x12)\n\x06status\x12\x0e.StatusRequest\x1a\x0f.StatusResponse\x12\x38\n\x0b\x61\x64\x64\x43\x61talogs\x12\x13.AddCatalogsRequest\x1a\x14.AddCatalogsResponse\x12I\n\x16getAddCatalogsResponse\x12\x16.GetAddCatalogsRequest\x1a\x17.GetAddCatalogsResponse\x12;\n\x0cgetCataloges\x12\x14.GetCatalogesRequest\x1a\x15.GetCatalogesResponse\x12\x45\n\x18getNextRemoteCachedChunk\x12\x13.RemoteChunkRequest\x1a\x14.RemoteChunkResponse\x12\x44\n\x0frefreshCatalogs\x12\x17.RefreshCatalogsRequest\x1a\x18.RefreshCatalogsResponseB\x02P\x01\x62\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'e6x_engine_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'P\001' +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'P\001' _globals['_GFIELDINFO']._serialized_start=20 _globals['_GFIELDINFO']._serialized_end=70 _globals['_FAILEDSCHEMAELEMENT']._serialized_start=72 @@ -55,86 +56,86 @@ _globals['_EXPLAINANALYZERESPONSE']._serialized_end=1057 _globals['_PREPARESTATEMENTREQUEST']._serialized_start=1059 _globals['_PREPARESTATEMENTREQUEST']._serialized_end=1157 - _globals['_PREPARESTATEMENTV2REQUEST']._serialized_start=1159 - _globals['_PREPARESTATEMENTV2REQUEST']._serialized_end=1276 - _globals['_PREPARESTATEMENTRESPONSE']._serialized_start=1278 - _globals['_PREPARESTATEMENTRESPONSE']._serialized_end=1339 - _globals['_USERACCESSINFO']._serialized_start=1341 - _globals['_USERACCESSINFO']._serialized_end=1405 - _globals['_EXECUTESTATEMENTREQUEST']._serialized_start=1407 - _globals['_EXECUTESTATEMENTREQUEST']._serialized_end=1510 - _globals['_EXECUTESTATEMENTV2REQUEST']._serialized_start=1513 - _globals['_EXECUTESTATEMENTV2REQUEST']._serialized_end=1651 - _globals['_EXECUTESTATEMENTRESPONSE']._serialized_start=1653 - _globals['_EXECUTESTATEMENTRESPONSE']._serialized_end=1679 - _globals['_GETNEXTRESULTROWREQUEST']._serialized_start=1681 - _globals['_GETNEXTRESULTROWREQUEST']._serialized_end=1760 - _globals['_GETNEXTRESULTROWRESPONSE']._serialized_start=1762 - _globals['_GETNEXTRESULTROWRESPONSE']._serialized_end=1807 - _globals['_GETNEXTRESULTBATCHREQUEST']._serialized_start=1809 - _globals['_GETNEXTRESULTBATCHREQUEST']._serialized_end=1928 - _globals['_GETNEXTRESULTBATCHRESPONSE']._serialized_start=1930 - _globals['_GETNEXTRESULTBATCHRESPONSE']._serialized_end=1979 - _globals['_GETRESULTMETADATAREQUEST']._serialized_start=1981 - _globals['_GETRESULTMETADATAREQUEST']._serialized_end=2061 - _globals['_GETRESULTMETADATARESPONSE']._serialized_start=2063 - _globals['_GETRESULTMETADATARESPONSE']._serialized_end=2114 - _globals['_AUTHENTICATEREQUEST']._serialized_start=2116 - _globals['_AUTHENTICATEREQUEST']._serialized_end=2169 - _globals['_AUTHENTICATERESPONSE']._serialized_start=2171 - _globals['_AUTHENTICATERESPONSE']._serialized_end=2212 - _globals['_GETTABLESREQUEST']._serialized_start=2214 - _globals['_GETTABLESREQUEST']._serialized_end=2267 - _globals['_GETTABLESV2REQUEST']._serialized_start=2269 - _globals['_GETTABLESV2REQUEST']._serialized_end=2341 - _globals['_GETTABLESRESPONSE']._serialized_start=2343 - _globals['_GETTABLESRESPONSE']._serialized_end=2378 - _globals['_GETSCHEMANAMESREQUEST']._serialized_start=2380 - _globals['_GETSCHEMANAMESREQUEST']._serialized_end=2422 - _globals['_GETSCHEMANAMESV2REQUEST']._serialized_start=2424 - _globals['_GETSCHEMANAMESV2REQUEST']._serialized_end=2485 - _globals['_GETSCHEMANAMESRESPONSE']._serialized_start=2487 - _globals['_GETSCHEMANAMESRESPONSE']._serialized_end=2528 - _globals['_GETCOLUMNSREQUEST']._serialized_start=2530 - _globals['_GETCOLUMNSREQUEST']._serialized_end=2599 - _globals['_GETCOLUMNSV2REQUEST']._serialized_start=2601 - _globals['_GETCOLUMNSV2REQUEST']._serialized_end=2689 - _globals['_GETCOLUMNSRESPONSE']._serialized_start=2691 - _globals['_GETCOLUMNSRESPONSE']._serialized_end=2743 - _globals['_STATUSREQUEST']._serialized_start=2745 - _globals['_STATUSREQUEST']._serialized_end=2814 - _globals['_STATUSRESPONSE']._serialized_start=2816 - _globals['_STATUSRESPONSE']._serialized_end=2866 - _globals['_ADDCATALOGSREQUEST']._serialized_start=2868 - _globals['_ADDCATALOGSREQUEST']._serialized_end=2921 - _globals['_UPDATEUSERSREQUEST']._serialized_start=2923 - _globals['_UPDATEUSERSREQUEST']._serialized_end=2958 - _globals['_UPDATEUSERSRESPONSE']._serialized_start=2960 - _globals['_UPDATEUSERSRESPONSE']._serialized_end=2981 - _globals['_SETPROPSREQUEST']._serialized_start=2983 - _globals['_SETPROPSREQUEST']._serialized_end=3034 - _globals['_SETPROPSRESPONSE']._serialized_start=3036 - _globals['_SETPROPSRESPONSE']._serialized_end=3054 - _globals['_GETADDCATALOGSREQUEST']._serialized_start=3056 - _globals['_GETADDCATALOGSREQUEST']._serialized_end=3098 - _globals['_ADDCATALOGSRESPONSE']._serialized_start=3100 - _globals['_ADDCATALOGSRESPONSE']._serialized_end=3121 - _globals['_GETCATALOGESREQUEST']._serialized_start=3123 - _globals['_GETCATALOGESREQUEST']._serialized_end=3144 - _globals['_GETCATALOGESRESPONSE']._serialized_start=3146 - _globals['_GETCATALOGESRESPONSE']._serialized_end=3212 - _globals['_REFRESHCATALOGSREQUEST']._serialized_start=3214 - _globals['_REFRESHCATALOGSREQUEST']._serialized_end=3257 - _globals['_REFRESHCATALOGSRESPONSE']._serialized_start=3259 - _globals['_REFRESHCATALOGSRESPONSE']._serialized_end=3284 - _globals['_REMOTECHUNKREQUEST']._serialized_start=3286 - _globals['_REMOTECHUNKREQUEST']._serialized_end=3374 - _globals['_REMOTECHUNKRESPONSE']._serialized_start=3376 - _globals['_REMOTECHUNKRESPONSE']._serialized_end=3427 - _globals['_CLEARORCANCELQUERYREQUEST']._serialized_start=3429 - _globals['_CLEARORCANCELQUERYREQUEST']._serialized_end=3510 - _globals['_CLEARORCANCELQUERYRESPONSE']._serialized_start=3512 - _globals['_CLEARORCANCELQUERYRESPONSE']._serialized_end=3540 - _globals['_QUERYENGINESERVICE']._serialized_start=3543 - _globals['_QUERYENGINESERVICE']._serialized_end=5377 + _globals['_PREPARESTATEMENTV2REQUEST']._serialized_start=1160 + _globals['_PREPARESTATEMENTV2REQUEST']._serialized_end=1315 + _globals['_PREPARESTATEMENTRESPONSE']._serialized_start=1317 + _globals['_PREPARESTATEMENTRESPONSE']._serialized_end=1378 + _globals['_USERACCESSINFO']._serialized_start=1380 + _globals['_USERACCESSINFO']._serialized_end=1444 + _globals['_EXECUTESTATEMENTREQUEST']._serialized_start=1446 + _globals['_EXECUTESTATEMENTREQUEST']._serialized_end=1549 + _globals['_EXECUTESTATEMENTV2REQUEST']._serialized_start=1552 + _globals['_EXECUTESTATEMENTV2REQUEST']._serialized_end=1690 + _globals['_EXECUTESTATEMENTRESPONSE']._serialized_start=1692 + _globals['_EXECUTESTATEMENTRESPONSE']._serialized_end=1718 + _globals['_GETNEXTRESULTROWREQUEST']._serialized_start=1720 + _globals['_GETNEXTRESULTROWREQUEST']._serialized_end=1799 + _globals['_GETNEXTRESULTROWRESPONSE']._serialized_start=1801 + _globals['_GETNEXTRESULTROWRESPONSE']._serialized_end=1846 + _globals['_GETNEXTRESULTBATCHREQUEST']._serialized_start=1848 + _globals['_GETNEXTRESULTBATCHREQUEST']._serialized_end=1967 + _globals['_GETNEXTRESULTBATCHRESPONSE']._serialized_start=1969 + _globals['_GETNEXTRESULTBATCHRESPONSE']._serialized_end=2018 + _globals['_GETRESULTMETADATAREQUEST']._serialized_start=2020 + _globals['_GETRESULTMETADATAREQUEST']._serialized_end=2100 + _globals['_GETRESULTMETADATARESPONSE']._serialized_start=2102 + _globals['_GETRESULTMETADATARESPONSE']._serialized_end=2153 + _globals['_AUTHENTICATEREQUEST']._serialized_start=2155 + _globals['_AUTHENTICATEREQUEST']._serialized_end=2208 + _globals['_AUTHENTICATERESPONSE']._serialized_start=2210 + _globals['_AUTHENTICATERESPONSE']._serialized_end=2270 + _globals['_GETTABLESREQUEST']._serialized_start=2272 + _globals['_GETTABLESREQUEST']._serialized_end=2325 + _globals['_GETTABLESV2REQUEST']._serialized_start=2327 + _globals['_GETTABLESV2REQUEST']._serialized_end=2399 + _globals['_GETTABLESRESPONSE']._serialized_start=2401 + _globals['_GETTABLESRESPONSE']._serialized_end=2436 + _globals['_GETSCHEMANAMESREQUEST']._serialized_start=2438 + _globals['_GETSCHEMANAMESREQUEST']._serialized_end=2480 + _globals['_GETSCHEMANAMESV2REQUEST']._serialized_start=2482 + _globals['_GETSCHEMANAMESV2REQUEST']._serialized_end=2543 + _globals['_GETSCHEMANAMESRESPONSE']._serialized_start=2545 + _globals['_GETSCHEMANAMESRESPONSE']._serialized_end=2586 + _globals['_GETCOLUMNSREQUEST']._serialized_start=2588 + _globals['_GETCOLUMNSREQUEST']._serialized_end=2657 + _globals['_GETCOLUMNSV2REQUEST']._serialized_start=2659 + _globals['_GETCOLUMNSV2REQUEST']._serialized_end=2747 + _globals['_GETCOLUMNSRESPONSE']._serialized_start=2749 + _globals['_GETCOLUMNSRESPONSE']._serialized_end=2801 + _globals['_STATUSREQUEST']._serialized_start=2803 + _globals['_STATUSREQUEST']._serialized_end=2872 + _globals['_STATUSRESPONSE']._serialized_start=2874 + _globals['_STATUSRESPONSE']._serialized_end=2924 + _globals['_ADDCATALOGSREQUEST']._serialized_start=2926 + _globals['_ADDCATALOGSREQUEST']._serialized_end=2979 + _globals['_UPDATEUSERSREQUEST']._serialized_start=2981 + _globals['_UPDATEUSERSREQUEST']._serialized_end=3016 + _globals['_UPDATEUSERSRESPONSE']._serialized_start=3018 + _globals['_UPDATEUSERSRESPONSE']._serialized_end=3039 + _globals['_SETPROPSREQUEST']._serialized_start=3041 + _globals['_SETPROPSREQUEST']._serialized_end=3092 + _globals['_SETPROPSRESPONSE']._serialized_start=3094 + _globals['_SETPROPSRESPONSE']._serialized_end=3112 + _globals['_GETADDCATALOGSREQUEST']._serialized_start=3114 + _globals['_GETADDCATALOGSREQUEST']._serialized_end=3156 + _globals['_ADDCATALOGSRESPONSE']._serialized_start=3158 + _globals['_ADDCATALOGSRESPONSE']._serialized_end=3179 + _globals['_GETCATALOGESREQUEST']._serialized_start=3181 + _globals['_GETCATALOGESREQUEST']._serialized_end=3202 + _globals['_GETCATALOGESRESPONSE']._serialized_start=3204 + _globals['_GETCATALOGESRESPONSE']._serialized_end=3270 + _globals['_REFRESHCATALOGSREQUEST']._serialized_start=3272 + _globals['_REFRESHCATALOGSREQUEST']._serialized_end=3315 + _globals['_REFRESHCATALOGSRESPONSE']._serialized_start=3317 + _globals['_REFRESHCATALOGSRESPONSE']._serialized_end=3342 + _globals['_REMOTECHUNKREQUEST']._serialized_start=3344 + _globals['_REMOTECHUNKREQUEST']._serialized_end=3432 + _globals['_REMOTECHUNKRESPONSE']._serialized_start=3434 + _globals['_REMOTECHUNKRESPONSE']._serialized_end=3485 + _globals['_CLEARORCANCELQUERYREQUEST']._serialized_start=3487 + _globals['_CLEARORCANCELQUERYREQUEST']._serialized_end=3568 + _globals['_CLEARORCANCELQUERYRESPONSE']._serialized_start=3570 + _globals['_CLEARORCANCELQUERYRESPONSE']._serialized_end=3598 + _globals['_QUERYENGINESERVICE']._serialized_start=3601 + _globals['_QUERYENGINESERVICE']._serialized_end=5435 # @@protoc_insertion_point(module_scope) diff --git a/e6data_python_connector/server/e6x_engine_pb2.pyi b/e6data_python_connector/server/e6x_engine_pb2.pyi index 90c6bc0..331fa22 100644 --- a/e6data_python_connector/server/e6x_engine_pb2.pyi +++ b/e6data_python_connector/server/e6x_engine_pb2.pyi @@ -6,7 +6,7 @@ from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Map DESCRIPTOR: _descriptor.FileDescriptor class GFieldInfo(_message.Message): - __slots__ = ["fieldName", "fieldType"] + __slots__ = ("fieldName", "fieldType") FIELDNAME_FIELD_NUMBER: _ClassVar[int] FIELDTYPE_FIELD_NUMBER: _ClassVar[int] fieldName: str @@ -14,7 +14,7 @@ class GFieldInfo(_message.Message): def __init__(self, fieldName: _Optional[str] = ..., fieldType: _Optional[str] = ...) -> None: ... class FailedSchemaElement(_message.Message): - __slots__ = ["name", "type", "reason"] + __slots__ = ("name", "type", "reason") NAME_FIELD_NUMBER: _ClassVar[int] TYPE_FIELD_NUMBER: _ClassVar[int] REASON_FIELD_NUMBER: _ClassVar[int] @@ -24,7 +24,7 @@ class FailedSchemaElement(_message.Message): def __init__(self, name: _Optional[str] = ..., type: _Optional[str] = ..., reason: _Optional[str] = ...) -> None: ... class GetAddCatalogsResponse(_message.Message): - __slots__ = ["status", "failures"] + __slots__ = ("status", "failures") STATUS_FIELD_NUMBER: _ClassVar[int] FAILURES_FIELD_NUMBER: _ClassVar[int] status: str @@ -32,7 +32,7 @@ class GetAddCatalogsResponse(_message.Message): def __init__(self, status: _Optional[str] = ..., failures: _Optional[_Iterable[_Union[FailedSchemaElement, _Mapping]]] = ...) -> None: ... class CatalogResponse(_message.Message): - __slots__ = ["name", "isDefault"] + __slots__ = ("name", "isDefault") NAME_FIELD_NUMBER: _ClassVar[int] ISDEFAULT_FIELD_NUMBER: _ClassVar[int] name: str @@ -40,7 +40,7 @@ class CatalogResponse(_message.Message): def __init__(self, name: _Optional[str] = ..., isDefault: bool = ...) -> None: ... class ParameterValue(_message.Message): - __slots__ = ["index", "type", "value"] + __slots__ = ("index", "type", "value") INDEX_FIELD_NUMBER: _ClassVar[int] TYPE_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] @@ -50,7 +50,7 @@ class ParameterValue(_message.Message): def __init__(self, index: _Optional[int] = ..., type: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ... class ClearRequest(_message.Message): - __slots__ = ["engineIP", "sessionId", "queryId"] + __slots__ = ("engineIP", "sessionId", "queryId") ENGINEIP_FIELD_NUMBER: _ClassVar[int] SESSIONID_FIELD_NUMBER: _ClassVar[int] QUERYID_FIELD_NUMBER: _ClassVar[int] @@ -60,11 +60,11 @@ class ClearRequest(_message.Message): def __init__(self, engineIP: _Optional[str] = ..., sessionId: _Optional[str] = ..., queryId: _Optional[str] = ...) -> None: ... class ClearResponse(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class CancelQueryRequest(_message.Message): - __slots__ = ["engineIP", "sessionId", "queryId"] + __slots__ = ("engineIP", "sessionId", "queryId") ENGINEIP_FIELD_NUMBER: _ClassVar[int] SESSIONID_FIELD_NUMBER: _ClassVar[int] QUERYID_FIELD_NUMBER: _ClassVar[int] @@ -74,11 +74,11 @@ class CancelQueryRequest(_message.Message): def __init__(self, engineIP: _Optional[str] = ..., sessionId: _Optional[str] = ..., queryId: _Optional[str] = ...) -> None: ... class CancelQueryResponse(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class ExplainRequest(_message.Message): - __slots__ = ["engineIP", "sessionId", "queryId"] + __slots__ = ("engineIP", "sessionId", "queryId") ENGINEIP_FIELD_NUMBER: _ClassVar[int] SESSIONID_FIELD_NUMBER: _ClassVar[int] QUERYID_FIELD_NUMBER: _ClassVar[int] @@ -88,13 +88,13 @@ class ExplainRequest(_message.Message): def __init__(self, engineIP: _Optional[str] = ..., sessionId: _Optional[str] = ..., queryId: _Optional[str] = ...) -> None: ... class ExplainResponse(_message.Message): - __slots__ = ["explain"] + __slots__ = ("explain",) EXPLAIN_FIELD_NUMBER: _ClassVar[int] explain: str def __init__(self, explain: _Optional[str] = ...) -> None: ... class DryRunRequest(_message.Message): - __slots__ = ["engineIP", "sessionId", "schema", "queryString"] + __slots__ = ("engineIP", "sessionId", "schema", "queryString") ENGINEIP_FIELD_NUMBER: _ClassVar[int] SESSIONID_FIELD_NUMBER: _ClassVar[int] SCHEMA_FIELD_NUMBER: _ClassVar[int] @@ -106,13 +106,13 @@ class DryRunRequest(_message.Message): def __init__(self, engineIP: _Optional[str] = ..., sessionId: _Optional[str] = ..., schema: _Optional[str] = ..., queryString: _Optional[str] = ...) -> None: ... class DryRunResponse(_message.Message): - __slots__ = ["dryrunValue"] + __slots__ = ("dryrunValue",) DRYRUNVALUE_FIELD_NUMBER: _ClassVar[int] dryrunValue: str def __init__(self, dryrunValue: _Optional[str] = ...) -> None: ... class DryRunRequestV2(_message.Message): - __slots__ = ["engineIP", "sessionId", "schema", "queryString", "catalog"] + __slots__ = ("engineIP", "sessionId", "schema", "queryString", "catalog") ENGINEIP_FIELD_NUMBER: _ClassVar[int] SESSIONID_FIELD_NUMBER: _ClassVar[int] SCHEMA_FIELD_NUMBER: _ClassVar[int] @@ -126,7 +126,7 @@ class DryRunRequestV2(_message.Message): def __init__(self, engineIP: _Optional[str] = ..., sessionId: _Optional[str] = ..., schema: _Optional[str] = ..., queryString: _Optional[str] = ..., catalog: _Optional[str] = ...) -> None: ... class ExplainAnalyzeRequest(_message.Message): - __slots__ = ["engineIP", "sessionId", "queryId"] + __slots__ = ("engineIP", "sessionId", "queryId") ENGINEIP_FIELD_NUMBER: _ClassVar[int] SESSIONID_FIELD_NUMBER: _ClassVar[int] QUERYID_FIELD_NUMBER: _ClassVar[int] @@ -136,7 +136,7 @@ class ExplainAnalyzeRequest(_message.Message): def __init__(self, engineIP: _Optional[str] = ..., sessionId: _Optional[str] = ..., queryId: _Optional[str] = ...) -> None: ... class ExplainAnalyzeResponse(_message.Message): - __slots__ = ["explainAnalyze", "isCached", "parsingTime", "queueingTime"] + __slots__ = ("explainAnalyze", "isCached", "parsingTime", "queueingTime") EXPLAINANALYZE_FIELD_NUMBER: _ClassVar[int] ISCACHED_FIELD_NUMBER: _ClassVar[int] PARSINGTIME_FIELD_NUMBER: _ClassVar[int] @@ -148,7 +148,7 @@ class ExplainAnalyzeResponse(_message.Message): def __init__(self, explainAnalyze: _Optional[str] = ..., isCached: bool = ..., parsingTime: _Optional[int] = ..., queueingTime: _Optional[int] = ...) -> None: ... class PrepareStatementRequest(_message.Message): - __slots__ = ["sessionId", "schema", "queryString", "quoting"] + __slots__ = ("sessionId", "schema", "queryString", "quoting") SESSIONID_FIELD_NUMBER: _ClassVar[int] SCHEMA_FIELD_NUMBER: _ClassVar[int] QUERYSTRING_FIELD_NUMBER: _ClassVar[int] @@ -160,21 +160,23 @@ class PrepareStatementRequest(_message.Message): def __init__(self, sessionId: _Optional[str] = ..., schema: _Optional[str] = ..., queryString: _Optional[str] = ..., quoting: _Optional[str] = ...) -> None: ... class PrepareStatementV2Request(_message.Message): - __slots__ = ["sessionId", "schema", "catalog", "queryString", "quoting"] + __slots__ = ("sessionId", "schema", "catalog", "queryString", "quoting", "plannerIp") SESSIONID_FIELD_NUMBER: _ClassVar[int] SCHEMA_FIELD_NUMBER: _ClassVar[int] CATALOG_FIELD_NUMBER: _ClassVar[int] QUERYSTRING_FIELD_NUMBER: _ClassVar[int] QUOTING_FIELD_NUMBER: _ClassVar[int] + PLANNERIP_FIELD_NUMBER: _ClassVar[int] sessionId: str schema: str catalog: str queryString: str quoting: str - def __init__(self, sessionId: _Optional[str] = ..., schema: _Optional[str] = ..., catalog: _Optional[str] = ..., queryString: _Optional[str] = ..., quoting: _Optional[str] = ...) -> None: ... + plannerIp: str + def __init__(self, sessionId: _Optional[str] = ..., schema: _Optional[str] = ..., catalog: _Optional[str] = ..., queryString: _Optional[str] = ..., quoting: _Optional[str] = ..., plannerIp: _Optional[str] = ...) -> None: ... class PrepareStatementResponse(_message.Message): - __slots__ = ["engineIP", "queryId"] + __slots__ = ("engineIP", "queryId") ENGINEIP_FIELD_NUMBER: _ClassVar[int] QUERYID_FIELD_NUMBER: _ClassVar[int] engineIP: str @@ -182,7 +184,7 @@ class PrepareStatementResponse(_message.Message): def __init__(self, engineIP: _Optional[str] = ..., queryId: _Optional[str] = ...) -> None: ... class UserAccessInfo(_message.Message): - __slots__ = ["uuid", "userName", "tokens"] + __slots__ = ("uuid", "userName", "tokens") UUID_FIELD_NUMBER: _ClassVar[int] USERNAME_FIELD_NUMBER: _ClassVar[int] TOKENS_FIELD_NUMBER: _ClassVar[int] @@ -192,7 +194,7 @@ class UserAccessInfo(_message.Message): def __init__(self, uuid: _Optional[str] = ..., userName: _Optional[str] = ..., tokens: _Optional[_Iterable[str]] = ...) -> None: ... class ExecuteStatementRequest(_message.Message): - __slots__ = ["engineIP", "sessionId", "queryId", "shouldNotCache"] + __slots__ = ("engineIP", "sessionId", "queryId", "shouldNotCache") ENGINEIP_FIELD_NUMBER: _ClassVar[int] SESSIONID_FIELD_NUMBER: _ClassVar[int] QUERYID_FIELD_NUMBER: _ClassVar[int] @@ -204,7 +206,7 @@ class ExecuteStatementRequest(_message.Message): def __init__(self, engineIP: _Optional[str] = ..., sessionId: _Optional[str] = ..., queryId: _Optional[str] = ..., shouldNotCache: bool = ...) -> None: ... class ExecuteStatementV2Request(_message.Message): - __slots__ = ["engineIP", "sessionId", "queryId", "shouldNotCache", "params"] + __slots__ = ("engineIP", "sessionId", "queryId", "shouldNotCache", "params") ENGINEIP_FIELD_NUMBER: _ClassVar[int] SESSIONID_FIELD_NUMBER: _ClassVar[int] QUERYID_FIELD_NUMBER: _ClassVar[int] @@ -218,11 +220,11 @@ class ExecuteStatementV2Request(_message.Message): def __init__(self, engineIP: _Optional[str] = ..., sessionId: _Optional[str] = ..., queryId: _Optional[str] = ..., shouldNotCache: bool = ..., params: _Optional[_Iterable[_Union[ParameterValue, _Mapping]]] = ...) -> None: ... class ExecuteStatementResponse(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class GetNextResultRowRequest(_message.Message): - __slots__ = ["engineIP", "sessionId", "queryId"] + __slots__ = ("engineIP", "sessionId", "queryId") ENGINEIP_FIELD_NUMBER: _ClassVar[int] SESSIONID_FIELD_NUMBER: _ClassVar[int] QUERYID_FIELD_NUMBER: _ClassVar[int] @@ -232,13 +234,13 @@ class GetNextResultRowRequest(_message.Message): def __init__(self, engineIP: _Optional[str] = ..., sessionId: _Optional[str] = ..., queryId: _Optional[str] = ...) -> None: ... class GetNextResultRowResponse(_message.Message): - __slots__ = ["resultRow"] + __slots__ = ("resultRow",) RESULTROW_FIELD_NUMBER: _ClassVar[int] resultRow: bytes def __init__(self, resultRow: _Optional[bytes] = ...) -> None: ... class GetNextResultBatchRequest(_message.Message): - __slots__ = ["engineIP", "sessionId", "queryId", "asRowData"] + __slots__ = ("engineIP", "sessionId", "queryId", "asRowData") ENGINEIP_FIELD_NUMBER: _ClassVar[int] SESSIONID_FIELD_NUMBER: _ClassVar[int] QUERYID_FIELD_NUMBER: _ClassVar[int] @@ -250,13 +252,13 @@ class GetNextResultBatchRequest(_message.Message): def __init__(self, engineIP: _Optional[str] = ..., sessionId: _Optional[str] = ..., queryId: _Optional[str] = ..., asRowData: bool = ...) -> None: ... class GetNextResultBatchResponse(_message.Message): - __slots__ = ["resultBatch"] + __slots__ = ("resultBatch",) RESULTBATCH_FIELD_NUMBER: _ClassVar[int] resultBatch: bytes def __init__(self, resultBatch: _Optional[bytes] = ...) -> None: ... class GetResultMetadataRequest(_message.Message): - __slots__ = ["engineIP", "sessionId", "queryId"] + __slots__ = ("engineIP", "sessionId", "queryId") ENGINEIP_FIELD_NUMBER: _ClassVar[int] SESSIONID_FIELD_NUMBER: _ClassVar[int] QUERYID_FIELD_NUMBER: _ClassVar[int] @@ -266,13 +268,13 @@ class GetResultMetadataRequest(_message.Message): def __init__(self, engineIP: _Optional[str] = ..., sessionId: _Optional[str] = ..., queryId: _Optional[str] = ...) -> None: ... class GetResultMetadataResponse(_message.Message): - __slots__ = ["resultMetaData"] + __slots__ = ("resultMetaData",) RESULTMETADATA_FIELD_NUMBER: _ClassVar[int] resultMetaData: bytes def __init__(self, resultMetaData: _Optional[bytes] = ...) -> None: ... class AuthenticateRequest(_message.Message): - __slots__ = ["user", "password"] + __slots__ = ("user", "password") USER_FIELD_NUMBER: _ClassVar[int] PASSWORD_FIELD_NUMBER: _ClassVar[int] user: str @@ -280,13 +282,15 @@ class AuthenticateRequest(_message.Message): def __init__(self, user: _Optional[str] = ..., password: _Optional[str] = ...) -> None: ... class AuthenticateResponse(_message.Message): - __slots__ = ["sessionId"] + __slots__ = ("sessionId", "plannerIp") SESSIONID_FIELD_NUMBER: _ClassVar[int] + PLANNERIP_FIELD_NUMBER: _ClassVar[int] sessionId: str - def __init__(self, sessionId: _Optional[str] = ...) -> None: ... + plannerIp: str + def __init__(self, sessionId: _Optional[str] = ..., plannerIp: _Optional[str] = ...) -> None: ... class GetTablesRequest(_message.Message): - __slots__ = ["sessionId", "schema"] + __slots__ = ("sessionId", "schema") SESSIONID_FIELD_NUMBER: _ClassVar[int] SCHEMA_FIELD_NUMBER: _ClassVar[int] sessionId: str @@ -294,7 +298,7 @@ class GetTablesRequest(_message.Message): def __init__(self, sessionId: _Optional[str] = ..., schema: _Optional[str] = ...) -> None: ... class GetTablesV2Request(_message.Message): - __slots__ = ["sessionId", "schema", "catalog"] + __slots__ = ("sessionId", "schema", "catalog") SESSIONID_FIELD_NUMBER: _ClassVar[int] SCHEMA_FIELD_NUMBER: _ClassVar[int] CATALOG_FIELD_NUMBER: _ClassVar[int] @@ -304,19 +308,19 @@ class GetTablesV2Request(_message.Message): def __init__(self, sessionId: _Optional[str] = ..., schema: _Optional[str] = ..., catalog: _Optional[str] = ...) -> None: ... class GetTablesResponse(_message.Message): - __slots__ = ["tables"] + __slots__ = ("tables",) TABLES_FIELD_NUMBER: _ClassVar[int] tables: _containers.RepeatedScalarFieldContainer[str] def __init__(self, tables: _Optional[_Iterable[str]] = ...) -> None: ... class GetSchemaNamesRequest(_message.Message): - __slots__ = ["sessionId"] + __slots__ = ("sessionId",) SESSIONID_FIELD_NUMBER: _ClassVar[int] sessionId: str def __init__(self, sessionId: _Optional[str] = ...) -> None: ... class GetSchemaNamesV2Request(_message.Message): - __slots__ = ["sessionId", "catalog"] + __slots__ = ("sessionId", "catalog") SESSIONID_FIELD_NUMBER: _ClassVar[int] CATALOG_FIELD_NUMBER: _ClassVar[int] sessionId: str @@ -324,13 +328,13 @@ class GetSchemaNamesV2Request(_message.Message): def __init__(self, sessionId: _Optional[str] = ..., catalog: _Optional[str] = ...) -> None: ... class GetSchemaNamesResponse(_message.Message): - __slots__ = ["schemas"] + __slots__ = ("schemas",) SCHEMAS_FIELD_NUMBER: _ClassVar[int] schemas: _containers.RepeatedScalarFieldContainer[str] def __init__(self, schemas: _Optional[_Iterable[str]] = ...) -> None: ... class GetColumnsRequest(_message.Message): - __slots__ = ["sessionId", "schema", "table"] + __slots__ = ("sessionId", "schema", "table") SESSIONID_FIELD_NUMBER: _ClassVar[int] SCHEMA_FIELD_NUMBER: _ClassVar[int] TABLE_FIELD_NUMBER: _ClassVar[int] @@ -340,7 +344,7 @@ class GetColumnsRequest(_message.Message): def __init__(self, sessionId: _Optional[str] = ..., schema: _Optional[str] = ..., table: _Optional[str] = ...) -> None: ... class GetColumnsV2Request(_message.Message): - __slots__ = ["sessionId", "schema", "table", "catalog"] + __slots__ = ("sessionId", "schema", "table", "catalog") SESSIONID_FIELD_NUMBER: _ClassVar[int] SCHEMA_FIELD_NUMBER: _ClassVar[int] TABLE_FIELD_NUMBER: _ClassVar[int] @@ -352,13 +356,13 @@ class GetColumnsV2Request(_message.Message): def __init__(self, sessionId: _Optional[str] = ..., schema: _Optional[str] = ..., table: _Optional[str] = ..., catalog: _Optional[str] = ...) -> None: ... class GetColumnsResponse(_message.Message): - __slots__ = ["fieldInfo"] + __slots__ = ("fieldInfo",) FIELDINFO_FIELD_NUMBER: _ClassVar[int] fieldInfo: _containers.RepeatedCompositeFieldContainer[GFieldInfo] def __init__(self, fieldInfo: _Optional[_Iterable[_Union[GFieldInfo, _Mapping]]] = ...) -> None: ... class StatusRequest(_message.Message): - __slots__ = ["engineIP", "sessionId", "queryId"] + __slots__ = ("engineIP", "sessionId", "queryId") ENGINEIP_FIELD_NUMBER: _ClassVar[int] SESSIONID_FIELD_NUMBER: _ClassVar[int] QUERYID_FIELD_NUMBER: _ClassVar[int] @@ -368,7 +372,7 @@ class StatusRequest(_message.Message): def __init__(self, engineIP: _Optional[str] = ..., sessionId: _Optional[str] = ..., queryId: _Optional[str] = ...) -> None: ... class StatusResponse(_message.Message): - __slots__ = ["status", "rowCount"] + __slots__ = ("status", "rowCount") STATUS_FIELD_NUMBER: _ClassVar[int] ROWCOUNT_FIELD_NUMBER: _ClassVar[int] status: bool @@ -376,7 +380,7 @@ class StatusResponse(_message.Message): def __init__(self, status: bool = ..., rowCount: _Optional[int] = ...) -> None: ... class AddCatalogsRequest(_message.Message): - __slots__ = ["sessionId", "json"] + __slots__ = ("sessionId", "json") SESSIONID_FIELD_NUMBER: _ClassVar[int] JSON_FIELD_NUMBER: _ClassVar[int] sessionId: str @@ -384,17 +388,17 @@ class AddCatalogsRequest(_message.Message): def __init__(self, sessionId: _Optional[str] = ..., json: _Optional[str] = ...) -> None: ... class UpdateUsersRequest(_message.Message): - __slots__ = ["users"] + __slots__ = ("users",) USERS_FIELD_NUMBER: _ClassVar[int] users: bytes def __init__(self, users: _Optional[bytes] = ...) -> None: ... class UpdateUsersResponse(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class SetPropsRequest(_message.Message): - __slots__ = ["sessionId", "props"] + __slots__ = ("sessionId", "props") SESSIONID_FIELD_NUMBER: _ClassVar[int] PROPS_FIELD_NUMBER: _ClassVar[int] sessionId: str @@ -402,41 +406,41 @@ class SetPropsRequest(_message.Message): def __init__(self, sessionId: _Optional[str] = ..., props: _Optional[str] = ...) -> None: ... class SetPropsResponse(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class GetAddCatalogsRequest(_message.Message): - __slots__ = ["sessionId"] + __slots__ = ("sessionId",) SESSIONID_FIELD_NUMBER: _ClassVar[int] sessionId: str def __init__(self, sessionId: _Optional[str] = ...) -> None: ... class AddCatalogsResponse(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class GetCatalogesRequest(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class GetCatalogesResponse(_message.Message): - __slots__ = ["catalogResponses"] + __slots__ = ("catalogResponses",) CATALOGRESPONSES_FIELD_NUMBER: _ClassVar[int] catalogResponses: _containers.RepeatedCompositeFieldContainer[CatalogResponse] def __init__(self, catalogResponses: _Optional[_Iterable[_Union[CatalogResponse, _Mapping]]] = ...) -> None: ... class RefreshCatalogsRequest(_message.Message): - __slots__ = ["sessionId"] + __slots__ = ("sessionId",) SESSIONID_FIELD_NUMBER: _ClassVar[int] sessionId: str def __init__(self, sessionId: _Optional[str] = ...) -> None: ... class RefreshCatalogsResponse(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class RemoteChunkRequest(_message.Message): - __slots__ = ["originalQueryId", "remoteQueryId", "sQueryHash"] + __slots__ = ("originalQueryId", "remoteQueryId", "sQueryHash") ORIGINALQUERYID_FIELD_NUMBER: _ClassVar[int] REMOTEQUERYID_FIELD_NUMBER: _ClassVar[int] SQUERYHASH_FIELD_NUMBER: _ClassVar[int] @@ -446,7 +450,7 @@ class RemoteChunkRequest(_message.Message): def __init__(self, originalQueryId: _Optional[str] = ..., remoteQueryId: _Optional[str] = ..., sQueryHash: _Optional[str] = ...) -> None: ... class RemoteChunkResponse(_message.Message): - __slots__ = ["error", "chunk"] + __slots__ = ("error", "chunk") ERROR_FIELD_NUMBER: _ClassVar[int] CHUNK_FIELD_NUMBER: _ClassVar[int] error: str @@ -454,7 +458,7 @@ class RemoteChunkResponse(_message.Message): def __init__(self, error: _Optional[str] = ..., chunk: _Optional[bytes] = ...) -> None: ... class ClearOrCancelQueryRequest(_message.Message): - __slots__ = ["engineIP", "sessionId", "queryId"] + __slots__ = ("engineIP", "sessionId", "queryId") ENGINEIP_FIELD_NUMBER: _ClassVar[int] SESSIONID_FIELD_NUMBER: _ClassVar[int] QUERYID_FIELD_NUMBER: _ClassVar[int] @@ -464,5 +468,5 @@ class ClearOrCancelQueryRequest(_message.Message): def __init__(self, engineIP: _Optional[str] = ..., sessionId: _Optional[str] = ..., queryId: _Optional[str] = ...) -> None: ... class ClearOrCancelQueryResponse(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... diff --git a/e6data_python_connector/server/e6x_engine_pb2_grpc.py b/e6data_python_connector/server/e6x_engine_pb2_grpc.py index 4b3fbf3..b573246 100644 --- a/e6data_python_connector/server/e6x_engine_pb2_grpc.py +++ b/e6data_python_connector/server/e6x_engine_pb2_grpc.py @@ -1,9 +1,34 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc +import warnings import e6data_python_connector.server.e6x_engine_pb2 as e6x__engine__pb2 +GRPC_GENERATED_VERSION = '1.65.1' +GRPC_VERSION = grpc.__version__ +EXPECTED_ERROR_RELEASE = '1.66.0' +SCHEDULED_RELEASE_DATE = 'August 6, 2024' +_version_not_supported = False + +try: + from grpc._utilities import first_version_is_lower + _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) +except ImportError: + _version_not_supported = True + +if _version_not_supported: + warnings.warn( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in e6x_engine_pb2_grpc.py depends on' + + f' grpcio>={GRPC_GENERATED_VERSION}.' + + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' + + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' + + f' This warning will become an error in {EXPECTED_ERROR_RELEASE},' + + f' scheduled for release on {SCHEDULED_RELEASE_DATE}.', + RuntimeWarning + ) + class QueryEngineServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,147 +43,147 @@ def __init__(self, channel): '/QueryEngineService/clear', request_serializer=e6x__engine__pb2.ClearRequest.SerializeToString, response_deserializer=e6x__engine__pb2.ClearResponse.FromString, - ) + _registered_method=True) self.cancelQuery = channel.unary_unary( '/QueryEngineService/cancelQuery', request_serializer=e6x__engine__pb2.CancelQueryRequest.SerializeToString, response_deserializer=e6x__engine__pb2.CancelQueryResponse.FromString, - ) + _registered_method=True) self.clearOrCancelQuery = channel.unary_unary( '/QueryEngineService/clearOrCancelQuery', request_serializer=e6x__engine__pb2.ClearOrCancelQueryRequest.SerializeToString, response_deserializer=e6x__engine__pb2.ClearOrCancelQueryResponse.FromString, - ) + _registered_method=True) self.explain = channel.unary_unary( '/QueryEngineService/explain', request_serializer=e6x__engine__pb2.ExplainRequest.SerializeToString, response_deserializer=e6x__engine__pb2.ExplainResponse.FromString, - ) + _registered_method=True) self.dryRun = channel.unary_unary( '/QueryEngineService/dryRun', request_serializer=e6x__engine__pb2.DryRunRequest.SerializeToString, response_deserializer=e6x__engine__pb2.DryRunResponse.FromString, - ) + _registered_method=True) self.dryRunV2 = channel.unary_unary( '/QueryEngineService/dryRunV2', request_serializer=e6x__engine__pb2.DryRunRequestV2.SerializeToString, response_deserializer=e6x__engine__pb2.DryRunResponse.FromString, - ) + _registered_method=True) self.explainAnalyze = channel.unary_unary( '/QueryEngineService/explainAnalyze', request_serializer=e6x__engine__pb2.ExplainAnalyzeRequest.SerializeToString, response_deserializer=e6x__engine__pb2.ExplainAnalyzeResponse.FromString, - ) + _registered_method=True) self.prepareStatement = channel.unary_unary( '/QueryEngineService/prepareStatement', request_serializer=e6x__engine__pb2.PrepareStatementRequest.SerializeToString, response_deserializer=e6x__engine__pb2.PrepareStatementResponse.FromString, - ) + _registered_method=True) self.prepareStatementV2 = channel.unary_unary( '/QueryEngineService/prepareStatementV2', request_serializer=e6x__engine__pb2.PrepareStatementV2Request.SerializeToString, response_deserializer=e6x__engine__pb2.PrepareStatementResponse.FromString, - ) + _registered_method=True) self.executeStatement = channel.unary_unary( '/QueryEngineService/executeStatement', request_serializer=e6x__engine__pb2.ExecuteStatementRequest.SerializeToString, response_deserializer=e6x__engine__pb2.ExecuteStatementResponse.FromString, - ) + _registered_method=True) self.executeStatementV2 = channel.unary_unary( '/QueryEngineService/executeStatementV2', request_serializer=e6x__engine__pb2.ExecuteStatementV2Request.SerializeToString, response_deserializer=e6x__engine__pb2.ExecuteStatementResponse.FromString, - ) + _registered_method=True) self.getNextResultRow = channel.unary_unary( '/QueryEngineService/getNextResultRow', request_serializer=e6x__engine__pb2.GetNextResultRowRequest.SerializeToString, response_deserializer=e6x__engine__pb2.GetNextResultRowResponse.FromString, - ) + _registered_method=True) self.getNextResultBatch = channel.unary_unary( '/QueryEngineService/getNextResultBatch', request_serializer=e6x__engine__pb2.GetNextResultBatchRequest.SerializeToString, response_deserializer=e6x__engine__pb2.GetNextResultBatchResponse.FromString, - ) + _registered_method=True) self.getResultMetadata = channel.unary_unary( '/QueryEngineService/getResultMetadata', request_serializer=e6x__engine__pb2.GetResultMetadataRequest.SerializeToString, response_deserializer=e6x__engine__pb2.GetResultMetadataResponse.FromString, - ) + _registered_method=True) self.authenticate = channel.unary_unary( '/QueryEngineService/authenticate', request_serializer=e6x__engine__pb2.AuthenticateRequest.SerializeToString, response_deserializer=e6x__engine__pb2.AuthenticateResponse.FromString, - ) + _registered_method=True) self.getTables = channel.unary_unary( '/QueryEngineService/getTables', request_serializer=e6x__engine__pb2.GetTablesRequest.SerializeToString, response_deserializer=e6x__engine__pb2.GetTablesResponse.FromString, - ) + _registered_method=True) self.getTablesV2 = channel.unary_unary( '/QueryEngineService/getTablesV2', request_serializer=e6x__engine__pb2.GetTablesV2Request.SerializeToString, response_deserializer=e6x__engine__pb2.GetTablesResponse.FromString, - ) + _registered_method=True) self.getSchemaNames = channel.unary_unary( '/QueryEngineService/getSchemaNames', request_serializer=e6x__engine__pb2.GetSchemaNamesRequest.SerializeToString, response_deserializer=e6x__engine__pb2.GetSchemaNamesResponse.FromString, - ) + _registered_method=True) self.getSchemaNamesV2 = channel.unary_unary( '/QueryEngineService/getSchemaNamesV2', request_serializer=e6x__engine__pb2.GetSchemaNamesV2Request.SerializeToString, response_deserializer=e6x__engine__pb2.GetSchemaNamesResponse.FromString, - ) + _registered_method=True) self.getColumns = channel.unary_unary( '/QueryEngineService/getColumns', request_serializer=e6x__engine__pb2.GetColumnsRequest.SerializeToString, response_deserializer=e6x__engine__pb2.GetColumnsResponse.FromString, - ) + _registered_method=True) self.getColumnsV2 = channel.unary_unary( '/QueryEngineService/getColumnsV2', request_serializer=e6x__engine__pb2.GetColumnsV2Request.SerializeToString, response_deserializer=e6x__engine__pb2.GetColumnsResponse.FromString, - ) + _registered_method=True) self.updateUsers = channel.unary_unary( '/QueryEngineService/updateUsers', request_serializer=e6x__engine__pb2.UpdateUsersRequest.SerializeToString, response_deserializer=e6x__engine__pb2.UpdateUsersResponse.FromString, - ) + _registered_method=True) self.setProps = channel.unary_unary( '/QueryEngineService/setProps', request_serializer=e6x__engine__pb2.SetPropsRequest.SerializeToString, response_deserializer=e6x__engine__pb2.SetPropsResponse.FromString, - ) + _registered_method=True) self.status = channel.unary_unary( '/QueryEngineService/status', request_serializer=e6x__engine__pb2.StatusRequest.SerializeToString, response_deserializer=e6x__engine__pb2.StatusResponse.FromString, - ) + _registered_method=True) self.addCatalogs = channel.unary_unary( '/QueryEngineService/addCatalogs', request_serializer=e6x__engine__pb2.AddCatalogsRequest.SerializeToString, response_deserializer=e6x__engine__pb2.AddCatalogsResponse.FromString, - ) + _registered_method=True) self.getAddCatalogsResponse = channel.unary_unary( '/QueryEngineService/getAddCatalogsResponse', request_serializer=e6x__engine__pb2.GetAddCatalogsRequest.SerializeToString, response_deserializer=e6x__engine__pb2.GetAddCatalogsResponse.FromString, - ) + _registered_method=True) self.getCataloges = channel.unary_unary( '/QueryEngineService/getCataloges', request_serializer=e6x__engine__pb2.GetCatalogesRequest.SerializeToString, response_deserializer=e6x__engine__pb2.GetCatalogesResponse.FromString, - ) + _registered_method=True) self.getNextRemoteCachedChunk = channel.unary_unary( '/QueryEngineService/getNextRemoteCachedChunk', request_serializer=e6x__engine__pb2.RemoteChunkRequest.SerializeToString, response_deserializer=e6x__engine__pb2.RemoteChunkResponse.FromString, - ) + _registered_method=True) self.refreshCatalogs = channel.unary_unary( '/QueryEngineService/refreshCatalogs', request_serializer=e6x__engine__pb2.RefreshCatalogsRequest.SerializeToString, response_deserializer=e6x__engine__pb2.RefreshCatalogsResponse.FromString, - ) + _registered_method=True) class QueryEngineServiceServicer(object): @@ -491,6 +516,7 @@ def add_QueryEngineServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'QueryEngineService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('QueryEngineService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -508,11 +534,21 @@ def clear(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/clear', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/clear', e6x__engine__pb2.ClearRequest.SerializeToString, e6x__engine__pb2.ClearResponse.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, + _registered_method=True) @staticmethod def cancelQuery(request, @@ -525,11 +561,21 @@ def cancelQuery(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/cancelQuery', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/cancelQuery', e6x__engine__pb2.CancelQueryRequest.SerializeToString, e6x__engine__pb2.CancelQueryResponse.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, + _registered_method=True) @staticmethod def clearOrCancelQuery(request, @@ -542,11 +588,21 @@ def clearOrCancelQuery(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/clearOrCancelQuery', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/clearOrCancelQuery', e6x__engine__pb2.ClearOrCancelQueryRequest.SerializeToString, e6x__engine__pb2.ClearOrCancelQueryResponse.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, + _registered_method=True) @staticmethod def explain(request, @@ -559,11 +615,21 @@ def explain(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/explain', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/explain', e6x__engine__pb2.ExplainRequest.SerializeToString, e6x__engine__pb2.ExplainResponse.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, + _registered_method=True) @staticmethod def dryRun(request, @@ -576,11 +642,21 @@ def dryRun(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/dryRun', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/dryRun', e6x__engine__pb2.DryRunRequest.SerializeToString, e6x__engine__pb2.DryRunResponse.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, + _registered_method=True) @staticmethod def dryRunV2(request, @@ -593,11 +669,21 @@ def dryRunV2(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/dryRunV2', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/dryRunV2', e6x__engine__pb2.DryRunRequestV2.SerializeToString, e6x__engine__pb2.DryRunResponse.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, + _registered_method=True) @staticmethod def explainAnalyze(request, @@ -610,11 +696,21 @@ def explainAnalyze(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/explainAnalyze', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/explainAnalyze', e6x__engine__pb2.ExplainAnalyzeRequest.SerializeToString, e6x__engine__pb2.ExplainAnalyzeResponse.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, + _registered_method=True) @staticmethod def prepareStatement(request, @@ -627,11 +723,21 @@ def prepareStatement(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/prepareStatement', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/prepareStatement', e6x__engine__pb2.PrepareStatementRequest.SerializeToString, e6x__engine__pb2.PrepareStatementResponse.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, + _registered_method=True) @staticmethod def prepareStatementV2(request, @@ -644,11 +750,21 @@ def prepareStatementV2(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/prepareStatementV2', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/prepareStatementV2', e6x__engine__pb2.PrepareStatementV2Request.SerializeToString, e6x__engine__pb2.PrepareStatementResponse.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, + _registered_method=True) @staticmethod def executeStatement(request, @@ -661,11 +777,21 @@ def executeStatement(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/executeStatement', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/executeStatement', e6x__engine__pb2.ExecuteStatementRequest.SerializeToString, e6x__engine__pb2.ExecuteStatementResponse.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, + _registered_method=True) @staticmethod def executeStatementV2(request, @@ -678,11 +804,21 @@ def executeStatementV2(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/executeStatementV2', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/executeStatementV2', e6x__engine__pb2.ExecuteStatementV2Request.SerializeToString, e6x__engine__pb2.ExecuteStatementResponse.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, + _registered_method=True) @staticmethod def getNextResultRow(request, @@ -695,11 +831,21 @@ def getNextResultRow(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/getNextResultRow', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/getNextResultRow', e6x__engine__pb2.GetNextResultRowRequest.SerializeToString, e6x__engine__pb2.GetNextResultRowResponse.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, + _registered_method=True) @staticmethod def getNextResultBatch(request, @@ -712,11 +858,21 @@ def getNextResultBatch(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/getNextResultBatch', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/getNextResultBatch', e6x__engine__pb2.GetNextResultBatchRequest.SerializeToString, e6x__engine__pb2.GetNextResultBatchResponse.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, + _registered_method=True) @staticmethod def getResultMetadata(request, @@ -729,11 +885,21 @@ def getResultMetadata(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/getResultMetadata', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/getResultMetadata', e6x__engine__pb2.GetResultMetadataRequest.SerializeToString, e6x__engine__pb2.GetResultMetadataResponse.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, + _registered_method=True) @staticmethod def authenticate(request, @@ -746,11 +912,21 @@ def authenticate(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/authenticate', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/authenticate', e6x__engine__pb2.AuthenticateRequest.SerializeToString, e6x__engine__pb2.AuthenticateResponse.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, + _registered_method=True) @staticmethod def getTables(request, @@ -763,11 +939,21 @@ def getTables(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/getTables', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/getTables', e6x__engine__pb2.GetTablesRequest.SerializeToString, e6x__engine__pb2.GetTablesResponse.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, + _registered_method=True) @staticmethod def getTablesV2(request, @@ -780,11 +966,21 @@ def getTablesV2(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/getTablesV2', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/getTablesV2', e6x__engine__pb2.GetTablesV2Request.SerializeToString, e6x__engine__pb2.GetTablesResponse.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, + _registered_method=True) @staticmethod def getSchemaNames(request, @@ -797,11 +993,21 @@ def getSchemaNames(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/getSchemaNames', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/getSchemaNames', e6x__engine__pb2.GetSchemaNamesRequest.SerializeToString, e6x__engine__pb2.GetSchemaNamesResponse.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, + _registered_method=True) @staticmethod def getSchemaNamesV2(request, @@ -814,11 +1020,21 @@ def getSchemaNamesV2(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/getSchemaNamesV2', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/getSchemaNamesV2', e6x__engine__pb2.GetSchemaNamesV2Request.SerializeToString, e6x__engine__pb2.GetSchemaNamesResponse.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, + _registered_method=True) @staticmethod def getColumns(request, @@ -831,11 +1047,21 @@ def getColumns(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/getColumns', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/getColumns', e6x__engine__pb2.GetColumnsRequest.SerializeToString, e6x__engine__pb2.GetColumnsResponse.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, + _registered_method=True) @staticmethod def getColumnsV2(request, @@ -848,11 +1074,21 @@ def getColumnsV2(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/getColumnsV2', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/getColumnsV2', e6x__engine__pb2.GetColumnsV2Request.SerializeToString, e6x__engine__pb2.GetColumnsResponse.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, + _registered_method=True) @staticmethod def updateUsers(request, @@ -865,11 +1101,21 @@ def updateUsers(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/updateUsers', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/updateUsers', e6x__engine__pb2.UpdateUsersRequest.SerializeToString, e6x__engine__pb2.UpdateUsersResponse.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, + _registered_method=True) @staticmethod def setProps(request, @@ -882,11 +1128,21 @@ def setProps(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/setProps', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/setProps', e6x__engine__pb2.SetPropsRequest.SerializeToString, e6x__engine__pb2.SetPropsResponse.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, + _registered_method=True) @staticmethod def status(request, @@ -899,11 +1155,21 @@ def status(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/status', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/status', e6x__engine__pb2.StatusRequest.SerializeToString, e6x__engine__pb2.StatusResponse.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, + _registered_method=True) @staticmethod def addCatalogs(request, @@ -916,11 +1182,21 @@ def addCatalogs(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/addCatalogs', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/addCatalogs', e6x__engine__pb2.AddCatalogsRequest.SerializeToString, e6x__engine__pb2.AddCatalogsResponse.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, + _registered_method=True) @staticmethod def getAddCatalogsResponse(request, @@ -933,11 +1209,21 @@ def getAddCatalogsResponse(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/getAddCatalogsResponse', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/getAddCatalogsResponse', e6x__engine__pb2.GetAddCatalogsRequest.SerializeToString, e6x__engine__pb2.GetAddCatalogsResponse.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, + _registered_method=True) @staticmethod def getCataloges(request, @@ -950,11 +1236,21 @@ def getCataloges(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/getCataloges', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/getCataloges', e6x__engine__pb2.GetCatalogesRequest.SerializeToString, e6x__engine__pb2.GetCatalogesResponse.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, + _registered_method=True) @staticmethod def getNextRemoteCachedChunk(request, @@ -967,11 +1263,21 @@ def getNextRemoteCachedChunk(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/getNextRemoteCachedChunk', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/getNextRemoteCachedChunk', e6x__engine__pb2.RemoteChunkRequest.SerializeToString, e6x__engine__pb2.RemoteChunkResponse.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, + _registered_method=True) @staticmethod def refreshCatalogs(request, @@ -984,8 +1290,18 @@ def refreshCatalogs(request, wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/QueryEngineService/refreshCatalogs', + return grpc.experimental.unary_unary( + request, + target, + '/QueryEngineService/refreshCatalogs', e6x__engine__pb2.RefreshCatalogsRequest.SerializeToString, e6x__engine__pb2.RefreshCatalogsResponse.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, + _registered_method=True) diff --git a/e6x_engine.proto b/e6x_engine.proto index d2b30b5..5cada1d 100644 --- a/e6x_engine.proto +++ b/e6x_engine.proto @@ -108,6 +108,7 @@ message PrepareStatementV2Request{ string catalog = 3; string queryString = 4; string quoting = 5; + optional string plannerIp = 6; } message PrepareStatementResponse{ string engineIP = 1; @@ -176,6 +177,7 @@ message AuthenticateRequest{ message AuthenticateResponse{ string sessionId = 1; + string plannerIp = 2; } message GetTablesRequest{ diff --git a/setup.py b/setup.py index 0b39e2a..e9886ed 100644 --- a/setup.py +++ b/setup.py @@ -12,7 +12,7 @@ import setuptools -VERSION = (2, 2, 2) +VERSION = (2, 2, 3, 'rc1') def get_long_desc():