9 from thrift.Thrift
import TType, TMessageType, TFrozenDict, TException, TApplicationException
10 from thrift.protocol.TProtocol
import TProtocolException
11 from thrift.TRecursive
import fix_spec
16 from thrift.Thrift
import TProcessor
17 from thrift.transport
import TTransport
276 def sql_execute(self, session, query, column_format, nonce, first_n, at_most_n):
289 def sql_execute_df(self, session, query, device_type, device_id, first_n, transport_method):
361 def render_vega(self, session, widget_id, vega_json, compression_level, nonce):
404 def create_dashboard(self, session, dashboard_name, dashboard_state, image_hash, dashboard_metadata):
416 def replace_dashboard(self, session, dashboard_id, dashboard_name, dashboard_owner, dashboard_state, image_hash, dashboard_metadata):
459 def share_dashboard(self, session, dashboard_id, groups, objects, permissions, grant_role):
556 def load_table(self, session, table_name, rows, column_names):
577 def create_table(self, session, table_name, row_desc, file_type, create_params):
600 def import_geo_table(self, session, table_name, file_name, copy_params, row_desc, create_params):
670 def start_query(self, leaf_session, parent_session, query_ra, just_explain, outer_fragment_indices):
677 - outer_fragment_indices
698 - is_final_subquery_result
777 def has_role(self, session, granteeName, roleName):
841 if oprot
is not None:
857 self._oprot.writeMessageBegin(
'connect', TMessageType.CALL, self.
_seqid)
863 self._oprot.writeMessageEnd()
864 self._oprot.trans.flush()
868 (fname, mtype, rseqid) = iprot.readMessageBegin()
869 if mtype == TMessageType.EXCEPTION:
870 x = TApplicationException()
872 iprot.readMessageEnd()
876 iprot.readMessageEnd()
877 if result.success
is not None:
878 return result.success
879 if result.e
is not None:
881 raise TApplicationException(TApplicationException.MISSING_RESULT,
"connect failed: unknown result")
894 self._oprot.writeMessageBegin(
'krb5_connect', TMessageType.CALL, self.
_seqid)
896 args.inputToken = inputToken
899 self._oprot.writeMessageEnd()
900 self._oprot.trans.flush()
904 (fname, mtype, rseqid) = iprot.readMessageBegin()
905 if mtype == TMessageType.EXCEPTION:
906 x = TApplicationException()
908 iprot.readMessageEnd()
912 iprot.readMessageEnd()
913 if result.success
is not None:
914 return result.success
915 if result.e
is not None:
917 raise TApplicationException(TApplicationException.MISSING_RESULT,
"krb5_connect failed: unknown result")
929 self._oprot.writeMessageBegin(
'disconnect', TMessageType.CALL, self.
_seqid)
931 args.session = session
933 self._oprot.writeMessageEnd()
934 self._oprot.trans.flush()
938 (fname, mtype, rseqid) = iprot.readMessageBegin()
939 if mtype == TMessageType.EXCEPTION:
940 x = TApplicationException()
942 iprot.readMessageEnd()
946 iprot.readMessageEnd()
947 if result.e
is not None:
962 self._oprot.writeMessageBegin(
'switch_database', TMessageType.CALL, self.
_seqid)
964 args.session = session
967 self._oprot.writeMessageEnd()
968 self._oprot.trans.flush()
972 (fname, mtype, rseqid) = iprot.readMessageBegin()
973 if mtype == TMessageType.EXCEPTION:
974 x = TApplicationException()
976 iprot.readMessageEnd()
980 iprot.readMessageEnd()
981 if result.e
is not None:
995 self._oprot.writeMessageBegin(
'clone_session', TMessageType.CALL, self.
_seqid)
997 args.session = session
999 self._oprot.writeMessageEnd()
1000 self._oprot.trans.flush()
1004 (fname, mtype, rseqid) = iprot.readMessageBegin()
1005 if mtype == TMessageType.EXCEPTION:
1006 x = TApplicationException()
1008 iprot.readMessageEnd()
1012 iprot.readMessageEnd()
1013 if result.success
is not None:
1014 return result.success
1015 if result.e
is not None:
1017 raise TApplicationException(TApplicationException.MISSING_RESULT,
"clone_session failed: unknown result")
1029 self._oprot.writeMessageBegin(
'get_server_status', TMessageType.CALL, self.
_seqid)
1031 args.session = session
1033 self._oprot.writeMessageEnd()
1034 self._oprot.trans.flush()
1038 (fname, mtype, rseqid) = iprot.readMessageBegin()
1039 if mtype == TMessageType.EXCEPTION:
1040 x = TApplicationException()
1042 iprot.readMessageEnd()
1046 iprot.readMessageEnd()
1047 if result.success
is not None:
1048 return result.success
1049 if result.e
is not None:
1051 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_server_status failed: unknown result")
1063 self._oprot.writeMessageBegin(
'get_status', TMessageType.CALL, self.
_seqid)
1065 args.session = session
1067 self._oprot.writeMessageEnd()
1068 self._oprot.trans.flush()
1072 (fname, mtype, rseqid) = iprot.readMessageBegin()
1073 if mtype == TMessageType.EXCEPTION:
1074 x = TApplicationException()
1076 iprot.readMessageEnd()
1080 iprot.readMessageEnd()
1081 if result.success
is not None:
1082 return result.success
1083 if result.e
is not None:
1085 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_status failed: unknown result")
1097 self._oprot.writeMessageBegin(
'get_hardware_info', TMessageType.CALL, self.
_seqid)
1099 args.session = session
1101 self._oprot.writeMessageEnd()
1102 self._oprot.trans.flush()
1106 (fname, mtype, rseqid) = iprot.readMessageBegin()
1107 if mtype == TMessageType.EXCEPTION:
1108 x = TApplicationException()
1110 iprot.readMessageEnd()
1114 iprot.readMessageEnd()
1115 if result.success
is not None:
1116 return result.success
1117 if result.e
is not None:
1119 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_hardware_info failed: unknown result")
1131 self._oprot.writeMessageBegin(
'get_tables', TMessageType.CALL, self.
_seqid)
1133 args.session = session
1135 self._oprot.writeMessageEnd()
1136 self._oprot.trans.flush()
1140 (fname, mtype, rseqid) = iprot.readMessageBegin()
1141 if mtype == TMessageType.EXCEPTION:
1142 x = TApplicationException()
1144 iprot.readMessageEnd()
1148 iprot.readMessageEnd()
1149 if result.success
is not None:
1150 return result.success
1151 if result.e
is not None:
1153 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_tables failed: unknown result")
1165 self._oprot.writeMessageBegin(
'get_physical_tables', TMessageType.CALL, self.
_seqid)
1167 args.session = session
1169 self._oprot.writeMessageEnd()
1170 self._oprot.trans.flush()
1174 (fname, mtype, rseqid) = iprot.readMessageBegin()
1175 if mtype == TMessageType.EXCEPTION:
1176 x = TApplicationException()
1178 iprot.readMessageEnd()
1182 iprot.readMessageEnd()
1183 if result.success
is not None:
1184 return result.success
1185 if result.e
is not None:
1187 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_physical_tables failed: unknown result")
1199 self._oprot.writeMessageBegin(
'get_views', TMessageType.CALL, self.
_seqid)
1201 args.session = session
1203 self._oprot.writeMessageEnd()
1204 self._oprot.trans.flush()
1208 (fname, mtype, rseqid) = iprot.readMessageBegin()
1209 if mtype == TMessageType.EXCEPTION:
1210 x = TApplicationException()
1212 iprot.readMessageEnd()
1216 iprot.readMessageEnd()
1217 if result.success
is not None:
1218 return result.success
1219 if result.e
is not None:
1221 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_views failed: unknown result")
1233 self._oprot.writeMessageBegin(
'get_tables_meta', TMessageType.CALL, self.
_seqid)
1235 args.session = session
1237 self._oprot.writeMessageEnd()
1238 self._oprot.trans.flush()
1242 (fname, mtype, rseqid) = iprot.readMessageBegin()
1243 if mtype == TMessageType.EXCEPTION:
1244 x = TApplicationException()
1246 iprot.readMessageEnd()
1250 iprot.readMessageEnd()
1251 if result.success
is not None:
1252 return result.success
1253 if result.e
is not None:
1255 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_tables_meta failed: unknown result")
1268 self._oprot.writeMessageBegin(
'get_table_details', TMessageType.CALL, self.
_seqid)
1270 args.session = session
1271 args.table_name = table_name
1273 self._oprot.writeMessageEnd()
1274 self._oprot.trans.flush()
1278 (fname, mtype, rseqid) = iprot.readMessageBegin()
1279 if mtype == TMessageType.EXCEPTION:
1280 x = TApplicationException()
1282 iprot.readMessageEnd()
1286 iprot.readMessageEnd()
1287 if result.success
is not None:
1288 return result.success
1289 if result.e
is not None:
1291 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_table_details failed: unknown result")
1304 self._oprot.writeMessageBegin(
'get_internal_table_details', TMessageType.CALL, self.
_seqid)
1306 args.session = session
1307 args.table_name = table_name
1309 self._oprot.writeMessageEnd()
1310 self._oprot.trans.flush()
1314 (fname, mtype, rseqid) = iprot.readMessageBegin()
1315 if mtype == TMessageType.EXCEPTION:
1316 x = TApplicationException()
1318 iprot.readMessageEnd()
1322 iprot.readMessageEnd()
1323 if result.success
is not None:
1324 return result.success
1325 if result.e
is not None:
1327 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_internal_table_details failed: unknown result")
1339 self._oprot.writeMessageBegin(
'get_users', TMessageType.CALL, self.
_seqid)
1341 args.session = session
1343 self._oprot.writeMessageEnd()
1344 self._oprot.trans.flush()
1348 (fname, mtype, rseqid) = iprot.readMessageBegin()
1349 if mtype == TMessageType.EXCEPTION:
1350 x = TApplicationException()
1352 iprot.readMessageEnd()
1356 iprot.readMessageEnd()
1357 if result.success
is not None:
1358 return result.success
1359 if result.e
is not None:
1361 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_users failed: unknown result")
1373 self._oprot.writeMessageBegin(
'get_databases', TMessageType.CALL, self.
_seqid)
1375 args.session = session
1377 self._oprot.writeMessageEnd()
1378 self._oprot.trans.flush()
1382 (fname, mtype, rseqid) = iprot.readMessageBegin()
1383 if mtype == TMessageType.EXCEPTION:
1384 x = TApplicationException()
1386 iprot.readMessageEnd()
1390 iprot.readMessageEnd()
1391 if result.success
is not None:
1392 return result.success
1393 if result.e
is not None:
1395 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_databases failed: unknown result")
1402 self._oprot.writeMessageBegin(
'get_version', TMessageType.CALL, self.
_seqid)
1405 self._oprot.writeMessageEnd()
1406 self._oprot.trans.flush()
1410 (fname, mtype, rseqid) = iprot.readMessageBegin()
1411 if mtype == TMessageType.EXCEPTION:
1412 x = TApplicationException()
1414 iprot.readMessageEnd()
1418 iprot.readMessageEnd()
1419 if result.success
is not None:
1420 return result.success
1421 if result.e
is not None:
1423 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_version failed: unknown result")
1435 self._oprot.writeMessageBegin(
'start_heap_profile', TMessageType.CALL, self.
_seqid)
1437 args.session = session
1439 self._oprot.writeMessageEnd()
1440 self._oprot.trans.flush()
1444 (fname, mtype, rseqid) = iprot.readMessageBegin()
1445 if mtype == TMessageType.EXCEPTION:
1446 x = TApplicationException()
1448 iprot.readMessageEnd()
1452 iprot.readMessageEnd()
1453 if result.e
is not None:
1467 self._oprot.writeMessageBegin(
'stop_heap_profile', TMessageType.CALL, self.
_seqid)
1469 args.session = session
1471 self._oprot.writeMessageEnd()
1472 self._oprot.trans.flush()
1476 (fname, mtype, rseqid) = iprot.readMessageBegin()
1477 if mtype == TMessageType.EXCEPTION:
1478 x = TApplicationException()
1480 iprot.readMessageEnd()
1484 iprot.readMessageEnd()
1485 if result.e
is not None:
1499 self._oprot.writeMessageBegin(
'get_heap_profile', TMessageType.CALL, self.
_seqid)
1501 args.session = session
1503 self._oprot.writeMessageEnd()
1504 self._oprot.trans.flush()
1508 (fname, mtype, rseqid) = iprot.readMessageBegin()
1509 if mtype == TMessageType.EXCEPTION:
1510 x = TApplicationException()
1512 iprot.readMessageEnd()
1516 iprot.readMessageEnd()
1517 if result.success
is not None:
1518 return result.success
1519 if result.e
is not None:
1521 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_heap_profile failed: unknown result")
1534 self._oprot.writeMessageBegin(
'get_memory', TMessageType.CALL, self.
_seqid)
1536 args.session = session
1537 args.memory_level = memory_level
1539 self._oprot.writeMessageEnd()
1540 self._oprot.trans.flush()
1544 (fname, mtype, rseqid) = iprot.readMessageBegin()
1545 if mtype == TMessageType.EXCEPTION:
1546 x = TApplicationException()
1548 iprot.readMessageEnd()
1552 iprot.readMessageEnd()
1553 if result.success
is not None:
1554 return result.success
1555 if result.e
is not None:
1557 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_memory failed: unknown result")
1569 self._oprot.writeMessageBegin(
'clear_cpu_memory', TMessageType.CALL, self.
_seqid)
1571 args.session = session
1573 self._oprot.writeMessageEnd()
1574 self._oprot.trans.flush()
1578 (fname, mtype, rseqid) = iprot.readMessageBegin()
1579 if mtype == TMessageType.EXCEPTION:
1580 x = TApplicationException()
1582 iprot.readMessageEnd()
1586 iprot.readMessageEnd()
1587 if result.e
is not None:
1601 self._oprot.writeMessageBegin(
'clear_gpu_memory', TMessageType.CALL, self.
_seqid)
1603 args.session = session
1605 self._oprot.writeMessageEnd()
1606 self._oprot.trans.flush()
1610 (fname, mtype, rseqid) = iprot.readMessageBegin()
1611 if mtype == TMessageType.EXCEPTION:
1612 x = TApplicationException()
1614 iprot.readMessageEnd()
1618 iprot.readMessageEnd()
1619 if result.e
is not None:
1636 self._oprot.writeMessageBegin(
'set_table_epoch', TMessageType.CALL, self.
_seqid)
1638 args.session = session
1640 args.table_id = table_id
1641 args.new_epoch = new_epoch
1643 self._oprot.writeMessageEnd()
1644 self._oprot.trans.flush()
1648 (fname, mtype, rseqid) = iprot.readMessageBegin()
1649 if mtype == TMessageType.EXCEPTION:
1650 x = TApplicationException()
1652 iprot.readMessageEnd()
1656 iprot.readMessageEnd()
1657 if result.e
is not None:
1673 self._oprot.writeMessageBegin(
'set_table_epoch_by_name', TMessageType.CALL, self.
_seqid)
1675 args.session = session
1676 args.table_name = table_name
1677 args.new_epoch = new_epoch
1679 self._oprot.writeMessageEnd()
1680 self._oprot.trans.flush()
1684 (fname, mtype, rseqid) = iprot.readMessageBegin()
1685 if mtype == TMessageType.EXCEPTION:
1686 x = TApplicationException()
1688 iprot.readMessageEnd()
1692 iprot.readMessageEnd()
1693 if result.e
is not None:
1709 self._oprot.writeMessageBegin(
'get_table_epoch', TMessageType.CALL, self.
_seqid)
1711 args.session = session
1713 args.table_id = table_id
1715 self._oprot.writeMessageEnd()
1716 self._oprot.trans.flush()
1720 (fname, mtype, rseqid) = iprot.readMessageBegin()
1721 if mtype == TMessageType.EXCEPTION:
1722 x = TApplicationException()
1724 iprot.readMessageEnd()
1728 iprot.readMessageEnd()
1729 if result.success
is not None:
1730 return result.success
1731 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_table_epoch failed: unknown result")
1744 self._oprot.writeMessageBegin(
'get_table_epoch_by_name', TMessageType.CALL, self.
_seqid)
1746 args.session = session
1747 args.table_name = table_name
1749 self._oprot.writeMessageEnd()
1750 self._oprot.trans.flush()
1754 (fname, mtype, rseqid) = iprot.readMessageBegin()
1755 if mtype == TMessageType.EXCEPTION:
1756 x = TApplicationException()
1758 iprot.readMessageEnd()
1762 iprot.readMessageEnd()
1763 if result.success
is not None:
1764 return result.success
1765 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_table_epoch_by_name failed: unknown result")
1779 self._oprot.writeMessageBegin(
'get_table_epochs', TMessageType.CALL, self.
_seqid)
1781 args.session = session
1783 args.table_id = table_id
1785 self._oprot.writeMessageEnd()
1786 self._oprot.trans.flush()
1790 (fname, mtype, rseqid) = iprot.readMessageBegin()
1791 if mtype == TMessageType.EXCEPTION:
1792 x = TApplicationException()
1794 iprot.readMessageEnd()
1798 iprot.readMessageEnd()
1799 if result.success
is not None:
1800 return result.success
1801 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_table_epochs failed: unknown result")
1815 self._oprot.writeMessageBegin(
'set_table_epochs', TMessageType.CALL, self.
_seqid)
1817 args.session = session
1819 args.table_epochs = table_epochs
1821 self._oprot.writeMessageEnd()
1822 self._oprot.trans.flush()
1826 (fname, mtype, rseqid) = iprot.readMessageBegin()
1827 if mtype == TMessageType.EXCEPTION:
1828 x = TApplicationException()
1830 iprot.readMessageEnd()
1834 iprot.readMessageEnd()
1847 self._oprot.writeMessageBegin(
'get_session_info', TMessageType.CALL, self.
_seqid)
1849 args.session = session
1851 self._oprot.writeMessageEnd()
1852 self._oprot.trans.flush()
1856 (fname, mtype, rseqid) = iprot.readMessageBegin()
1857 if mtype == TMessageType.EXCEPTION:
1858 x = TApplicationException()
1860 iprot.readMessageEnd()
1864 iprot.readMessageEnd()
1865 if result.success
is not None:
1866 return result.success
1867 if result.e
is not None:
1869 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_session_info failed: unknown result")
1871 def sql_execute(self, session, query, column_format, nonce, first_n, at_most_n):
1882 self.
send_sql_execute(session, query, column_format, nonce, first_n, at_most_n)
1886 self._oprot.writeMessageBegin(
'sql_execute', TMessageType.CALL, self.
_seqid)
1888 args.session = session
1890 args.column_format = column_format
1892 args.first_n = first_n
1893 args.at_most_n = at_most_n
1895 self._oprot.writeMessageEnd()
1896 self._oprot.trans.flush()
1900 (fname, mtype, rseqid) = iprot.readMessageBegin()
1901 if mtype == TMessageType.EXCEPTION:
1902 x = TApplicationException()
1904 iprot.readMessageEnd()
1908 iprot.readMessageEnd()
1909 if result.success
is not None:
1910 return result.success
1911 if result.e
is not None:
1913 raise TApplicationException(TApplicationException.MISSING_RESULT,
"sql_execute failed: unknown result")
1915 def sql_execute_df(self, session, query, device_type, device_id, first_n, transport_method):
1926 self.
send_sql_execute_df(session, query, device_type, device_id, first_n, transport_method)
1930 self._oprot.writeMessageBegin(
'sql_execute_df', TMessageType.CALL, self.
_seqid)
1932 args.session = session
1934 args.device_type = device_type
1935 args.device_id = device_id
1936 args.first_n = first_n
1937 args.transport_method = transport_method
1939 self._oprot.writeMessageEnd()
1940 self._oprot.trans.flush()
1944 (fname, mtype, rseqid) = iprot.readMessageBegin()
1945 if mtype == TMessageType.EXCEPTION:
1946 x = TApplicationException()
1948 iprot.readMessageEnd()
1952 iprot.readMessageEnd()
1953 if result.success
is not None:
1954 return result.success
1955 if result.e
is not None:
1957 raise TApplicationException(TApplicationException.MISSING_RESULT,
"sql_execute_df failed: unknown result")
1972 self._oprot.writeMessageBegin(
'sql_execute_gdf', TMessageType.CALL, self.
_seqid)
1974 args.session = session
1976 args.device_id = device_id
1977 args.first_n = first_n
1979 self._oprot.writeMessageEnd()
1980 self._oprot.trans.flush()
1984 (fname, mtype, rseqid) = iprot.readMessageBegin()
1985 if mtype == TMessageType.EXCEPTION:
1986 x = TApplicationException()
1988 iprot.readMessageEnd()
1992 iprot.readMessageEnd()
1993 if result.success
is not None:
1994 return result.success
1995 if result.e
is not None:
1997 raise TApplicationException(TApplicationException.MISSING_RESULT,
"sql_execute_gdf failed: unknown result")
2012 self._oprot.writeMessageBegin(
'deallocate_df', TMessageType.CALL, self.
_seqid)
2014 args.session = session
2016 args.device_type = device_type
2017 args.device_id = device_id
2019 self._oprot.writeMessageEnd()
2020 self._oprot.trans.flush()
2024 (fname, mtype, rseqid) = iprot.readMessageBegin()
2025 if mtype == TMessageType.EXCEPTION:
2026 x = TApplicationException()
2028 iprot.readMessageEnd()
2032 iprot.readMessageEnd()
2033 if result.e
is not None:
2048 self._oprot.writeMessageBegin(
'interrupt', TMessageType.CALL, self.
_seqid)
2050 args.query_session = query_session
2051 args.interrupt_session = interrupt_session
2053 self._oprot.writeMessageEnd()
2054 self._oprot.trans.flush()
2058 (fname, mtype, rseqid) = iprot.readMessageBegin()
2059 if mtype == TMessageType.EXCEPTION:
2060 x = TApplicationException()
2062 iprot.readMessageEnd()
2066 iprot.readMessageEnd()
2067 if result.e
is not None:
2082 self._oprot.writeMessageBegin(
'sql_validate', TMessageType.CALL, self.
_seqid)
2084 args.session = session
2087 self._oprot.writeMessageEnd()
2088 self._oprot.trans.flush()
2092 (fname, mtype, rseqid) = iprot.readMessageBegin()
2093 if mtype == TMessageType.EXCEPTION:
2094 x = TApplicationException()
2096 iprot.readMessageEnd()
2100 iprot.readMessageEnd()
2101 if result.success
is not None:
2102 return result.success
2103 if result.e
is not None:
2105 raise TApplicationException(TApplicationException.MISSING_RESULT,
"sql_validate failed: unknown result")
2119 self._oprot.writeMessageBegin(
'get_completion_hints', TMessageType.CALL, self.
_seqid)
2121 args.session = session
2123 args.cursor = cursor
2125 self._oprot.writeMessageEnd()
2126 self._oprot.trans.flush()
2130 (fname, mtype, rseqid) = iprot.readMessageBegin()
2131 if mtype == TMessageType.EXCEPTION:
2132 x = TApplicationException()
2134 iprot.readMessageEnd()
2138 iprot.readMessageEnd()
2139 if result.success
is not None:
2140 return result.success
2141 if result.e
is not None:
2143 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_completion_hints failed: unknown result")
2156 self._oprot.writeMessageBegin(
'set_execution_mode', TMessageType.CALL, self.
_seqid)
2158 args.session = session
2161 self._oprot.writeMessageEnd()
2162 self._oprot.trans.flush()
2166 (fname, mtype, rseqid) = iprot.readMessageBegin()
2167 if mtype == TMessageType.EXCEPTION:
2168 x = TApplicationException()
2170 iprot.readMessageEnd()
2174 iprot.readMessageEnd()
2175 if result.e
is not None:
2179 def render_vega(self, session, widget_id, vega_json, compression_level, nonce):
2189 self.
send_render_vega(session, widget_id, vega_json, compression_level, nonce)
2193 self._oprot.writeMessageBegin(
'render_vega', TMessageType.CALL, self.
_seqid)
2195 args.session = session
2196 args.widget_id = widget_id
2197 args.vega_json = vega_json
2198 args.compression_level = compression_level
2201 self._oprot.writeMessageEnd()
2202 self._oprot.trans.flush()
2206 (fname, mtype, rseqid) = iprot.readMessageBegin()
2207 if mtype == TMessageType.EXCEPTION:
2208 x = TApplicationException()
2210 iprot.readMessageEnd()
2214 iprot.readMessageEnd()
2215 if result.success
is not None:
2216 return result.success
2217 if result.e
is not None:
2219 raise TApplicationException(TApplicationException.MISSING_RESULT,
"render_vega failed: unknown result")
2237 self._oprot.writeMessageBegin(
'get_result_row_for_pixel', TMessageType.CALL, self.
_seqid)
2239 args.session = session
2240 args.widget_id = widget_id
2242 args.table_col_names = table_col_names
2243 args.column_format = column_format
2244 args.pixelRadius = pixelRadius
2247 self._oprot.writeMessageEnd()
2248 self._oprot.trans.flush()
2252 (fname, mtype, rseqid) = iprot.readMessageBegin()
2253 if mtype == TMessageType.EXCEPTION:
2254 x = TApplicationException()
2256 iprot.readMessageEnd()
2260 iprot.readMessageEnd()
2261 if result.success
is not None:
2262 return result.success
2263 if result.e
is not None:
2265 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_result_row_for_pixel failed: unknown result")
2278 self._oprot.writeMessageBegin(
'get_dashboard', TMessageType.CALL, self.
_seqid)
2280 args.session = session
2281 args.dashboard_id = dashboard_id
2283 self._oprot.writeMessageEnd()
2284 self._oprot.trans.flush()
2288 (fname, mtype, rseqid) = iprot.readMessageBegin()
2289 if mtype == TMessageType.EXCEPTION:
2290 x = TApplicationException()
2292 iprot.readMessageEnd()
2296 iprot.readMessageEnd()
2297 if result.success
is not None:
2298 return result.success
2299 if result.e
is not None:
2301 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_dashboard failed: unknown result")
2313 self._oprot.writeMessageBegin(
'get_dashboards', TMessageType.CALL, self.
_seqid)
2315 args.session = session
2317 self._oprot.writeMessageEnd()
2318 self._oprot.trans.flush()
2322 (fname, mtype, rseqid) = iprot.readMessageBegin()
2323 if mtype == TMessageType.EXCEPTION:
2324 x = TApplicationException()
2326 iprot.readMessageEnd()
2330 iprot.readMessageEnd()
2331 if result.success
is not None:
2332 return result.success
2333 if result.e
is not None:
2335 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_dashboards failed: unknown result")
2337 def create_dashboard(self, session, dashboard_name, dashboard_state, image_hash, dashboard_metadata):
2344 - dashboard_metadata
2347 self.
send_create_dashboard(session, dashboard_name, dashboard_state, image_hash, dashboard_metadata)
2351 self._oprot.writeMessageBegin(
'create_dashboard', TMessageType.CALL, self.
_seqid)
2353 args.session = session
2354 args.dashboard_name = dashboard_name
2355 args.dashboard_state = dashboard_state
2356 args.image_hash = image_hash
2357 args.dashboard_metadata = dashboard_metadata
2359 self._oprot.writeMessageEnd()
2360 self._oprot.trans.flush()
2364 (fname, mtype, rseqid) = iprot.readMessageBegin()
2365 if mtype == TMessageType.EXCEPTION:
2366 x = TApplicationException()
2368 iprot.readMessageEnd()
2372 iprot.readMessageEnd()
2373 if result.success
is not None:
2374 return result.success
2375 if result.e
is not None:
2377 raise TApplicationException(TApplicationException.MISSING_RESULT,
"create_dashboard failed: unknown result")
2379 def replace_dashboard(self, session, dashboard_id, dashboard_name, dashboard_owner, dashboard_state, image_hash, dashboard_metadata):
2388 - dashboard_metadata
2391 self.
send_replace_dashboard(session, dashboard_id, dashboard_name, dashboard_owner, dashboard_state, image_hash, dashboard_metadata)
2394 def send_replace_dashboard(self, session, dashboard_id, dashboard_name, dashboard_owner, dashboard_state, image_hash, dashboard_metadata):
2395 self._oprot.writeMessageBegin(
'replace_dashboard', TMessageType.CALL, self.
_seqid)
2397 args.session = session
2398 args.dashboard_id = dashboard_id
2399 args.dashboard_name = dashboard_name
2400 args.dashboard_owner = dashboard_owner
2401 args.dashboard_state = dashboard_state
2402 args.image_hash = image_hash
2403 args.dashboard_metadata = dashboard_metadata
2405 self._oprot.writeMessageEnd()
2406 self._oprot.trans.flush()
2410 (fname, mtype, rseqid) = iprot.readMessageBegin()
2411 if mtype == TMessageType.EXCEPTION:
2412 x = TApplicationException()
2414 iprot.readMessageEnd()
2418 iprot.readMessageEnd()
2419 if result.e
is not None:
2434 self._oprot.writeMessageBegin(
'delete_dashboard', TMessageType.CALL, self.
_seqid)
2436 args.session = session
2437 args.dashboard_id = dashboard_id
2439 self._oprot.writeMessageEnd()
2440 self._oprot.trans.flush()
2444 (fname, mtype, rseqid) = iprot.readMessageBegin()
2445 if mtype == TMessageType.EXCEPTION:
2446 x = TApplicationException()
2448 iprot.readMessageEnd()
2452 iprot.readMessageEnd()
2453 if result.e
is not None:
2470 self._oprot.writeMessageBegin(
'share_dashboards', TMessageType.CALL, self.
_seqid)
2472 args.session = session
2473 args.dashboard_ids = dashboard_ids
2474 args.groups = groups
2475 args.permissions = permissions
2477 self._oprot.writeMessageEnd()
2478 self._oprot.trans.flush()
2482 (fname, mtype, rseqid) = iprot.readMessageBegin()
2483 if mtype == TMessageType.EXCEPTION:
2484 x = TApplicationException()
2486 iprot.readMessageEnd()
2490 iprot.readMessageEnd()
2491 if result.e
is not None:
2506 self._oprot.writeMessageBegin(
'delete_dashboards', TMessageType.CALL, self.
_seqid)
2508 args.session = session
2509 args.dashboard_ids = dashboard_ids
2511 self._oprot.writeMessageEnd()
2512 self._oprot.trans.flush()
2516 (fname, mtype, rseqid) = iprot.readMessageBegin()
2517 if mtype == TMessageType.EXCEPTION:
2518 x = TApplicationException()
2520 iprot.readMessageEnd()
2524 iprot.readMessageEnd()
2525 if result.e
is not None:
2529 def share_dashboard(self, session, dashboard_id, groups, objects, permissions, grant_role):
2544 self._oprot.writeMessageBegin(
'share_dashboard', TMessageType.CALL, self.
_seqid)
2546 args.session = session
2547 args.dashboard_id = dashboard_id
2548 args.groups = groups
2549 args.objects = objects
2550 args.permissions = permissions
2551 args.grant_role = grant_role
2553 self._oprot.writeMessageEnd()
2554 self._oprot.trans.flush()
2558 (fname, mtype, rseqid) = iprot.readMessageBegin()
2559 if mtype == TMessageType.EXCEPTION:
2560 x = TApplicationException()
2562 iprot.readMessageEnd()
2566 iprot.readMessageEnd()
2567 if result.e
is not None:
2585 self._oprot.writeMessageBegin(
'unshare_dashboard', TMessageType.CALL, self.
_seqid)
2587 args.session = session
2588 args.dashboard_id = dashboard_id
2589 args.groups = groups
2590 args.objects = objects
2591 args.permissions = permissions
2593 self._oprot.writeMessageEnd()
2594 self._oprot.trans.flush()
2598 (fname, mtype, rseqid) = iprot.readMessageBegin()
2599 if mtype == TMessageType.EXCEPTION:
2600 x = TApplicationException()
2602 iprot.readMessageEnd()
2606 iprot.readMessageEnd()
2607 if result.e
is not None:
2624 self._oprot.writeMessageBegin(
'unshare_dashboards', TMessageType.CALL, self.
_seqid)
2626 args.session = session
2627 args.dashboard_ids = dashboard_ids
2628 args.groups = groups
2629 args.permissions = permissions
2631 self._oprot.writeMessageEnd()
2632 self._oprot.trans.flush()
2636 (fname, mtype, rseqid) = iprot.readMessageBegin()
2637 if mtype == TMessageType.EXCEPTION:
2638 x = TApplicationException()
2640 iprot.readMessageEnd()
2644 iprot.readMessageEnd()
2645 if result.e
is not None:
2660 self._oprot.writeMessageBegin(
'get_dashboard_grantees', TMessageType.CALL, self.
_seqid)
2662 args.session = session
2663 args.dashboard_id = dashboard_id
2665 self._oprot.writeMessageEnd()
2666 self._oprot.trans.flush()
2670 (fname, mtype, rseqid) = iprot.readMessageBegin()
2671 if mtype == TMessageType.EXCEPTION:
2672 x = TApplicationException()
2674 iprot.readMessageEnd()
2678 iprot.readMessageEnd()
2679 if result.success
is not None:
2680 return result.success
2681 if result.e
is not None:
2683 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_dashboard_grantees failed: unknown result")
2696 self._oprot.writeMessageBegin(
'get_link_view', TMessageType.CALL, self.
_seqid)
2698 args.session = session
2701 self._oprot.writeMessageEnd()
2702 self._oprot.trans.flush()
2706 (fname, mtype, rseqid) = iprot.readMessageBegin()
2707 if mtype == TMessageType.EXCEPTION:
2708 x = TApplicationException()
2710 iprot.readMessageEnd()
2714 iprot.readMessageEnd()
2715 if result.success
is not None:
2716 return result.success
2717 if result.e
is not None:
2719 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_link_view failed: unknown result")
2733 self._oprot.writeMessageBegin(
'create_link', TMessageType.CALL, self.
_seqid)
2735 args.session = session
2736 args.view_state = view_state
2737 args.view_metadata = view_metadata
2739 self._oprot.writeMessageEnd()
2740 self._oprot.trans.flush()
2744 (fname, mtype, rseqid) = iprot.readMessageBegin()
2745 if mtype == TMessageType.EXCEPTION:
2746 x = TApplicationException()
2748 iprot.readMessageEnd()
2752 iprot.readMessageEnd()
2753 if result.success
is not None:
2754 return result.success
2755 if result.e
is not None:
2757 raise TApplicationException(TApplicationException.MISSING_RESULT,
"create_link failed: unknown result")
2772 self._oprot.writeMessageBegin(
'load_table_binary', TMessageType.CALL, self.
_seqid)
2774 args.session = session
2775 args.table_name = table_name
2777 args.column_names = column_names
2779 self._oprot.writeMessageEnd()
2780 self._oprot.trans.flush()
2784 (fname, mtype, rseqid) = iprot.readMessageBegin()
2785 if mtype == TMessageType.EXCEPTION:
2786 x = TApplicationException()
2788 iprot.readMessageEnd()
2792 iprot.readMessageEnd()
2793 if result.e
is not None:
2810 self._oprot.writeMessageBegin(
'load_table_binary_columnar', TMessageType.CALL, self.
_seqid)
2812 args.session = session
2813 args.table_name = table_name
2815 args.column_names = column_names
2817 self._oprot.writeMessageEnd()
2818 self._oprot.trans.flush()
2822 (fname, mtype, rseqid) = iprot.readMessageBegin()
2823 if mtype == TMessageType.EXCEPTION:
2824 x = TApplicationException()
2826 iprot.readMessageEnd()
2830 iprot.readMessageEnd()
2831 if result.e
is not None:
2848 self._oprot.writeMessageBegin(
'load_table_binary_arrow', TMessageType.CALL, self.
_seqid)
2850 args.session = session
2851 args.table_name = table_name
2852 args.arrow_stream = arrow_stream
2853 args.use_column_names = use_column_names
2855 self._oprot.writeMessageEnd()
2856 self._oprot.trans.flush()
2860 (fname, mtype, rseqid) = iprot.readMessageBegin()
2861 if mtype == TMessageType.EXCEPTION:
2862 x = TApplicationException()
2864 iprot.readMessageEnd()
2868 iprot.readMessageEnd()
2869 if result.e
is not None:
2886 self._oprot.writeMessageBegin(
'load_table', TMessageType.CALL, self.
_seqid)
2888 args.session = session
2889 args.table_name = table_name
2891 args.column_names = column_names
2893 self._oprot.writeMessageEnd()
2894 self._oprot.trans.flush()
2898 (fname, mtype, rseqid) = iprot.readMessageBegin()
2899 if mtype == TMessageType.EXCEPTION:
2900 x = TApplicationException()
2902 iprot.readMessageEnd()
2906 iprot.readMessageEnd()
2907 if result.e
is not None:
2923 self._oprot.writeMessageBegin(
'detect_column_types', TMessageType.CALL, self.
_seqid)
2925 args.session = session
2926 args.file_name = file_name
2927 args.copy_params = copy_params
2929 self._oprot.writeMessageEnd()
2930 self._oprot.trans.flush()
2934 (fname, mtype, rseqid) = iprot.readMessageBegin()
2935 if mtype == TMessageType.EXCEPTION:
2936 x = TApplicationException()
2938 iprot.readMessageEnd()
2942 iprot.readMessageEnd()
2943 if result.success
is not None:
2944 return result.success
2945 if result.e
is not None:
2947 raise TApplicationException(TApplicationException.MISSING_RESULT,
"detect_column_types failed: unknown result")
2949 def create_table(self, session, table_name, row_desc, file_type, create_params):
2963 self._oprot.writeMessageBegin(
'create_table', TMessageType.CALL, self.
_seqid)
2965 args.session = session
2966 args.table_name = table_name
2967 args.row_desc = row_desc
2968 args.file_type = file_type
2969 args.create_params = create_params
2971 self._oprot.writeMessageEnd()
2972 self._oprot.trans.flush()
2976 (fname, mtype, rseqid) = iprot.readMessageBegin()
2977 if mtype == TMessageType.EXCEPTION:
2978 x = TApplicationException()
2980 iprot.readMessageEnd()
2984 iprot.readMessageEnd()
2985 if result.e
is not None:
3002 self._oprot.writeMessageBegin(
'import_table', TMessageType.CALL, self.
_seqid)
3004 args.session = session
3005 args.table_name = table_name
3006 args.file_name = file_name
3007 args.copy_params = copy_params
3009 self._oprot.writeMessageEnd()
3010 self._oprot.trans.flush()
3014 (fname, mtype, rseqid) = iprot.readMessageBegin()
3015 if mtype == TMessageType.EXCEPTION:
3016 x = TApplicationException()
3018 iprot.readMessageEnd()
3022 iprot.readMessageEnd()
3023 if result.e
is not None:
3027 def import_geo_table(self, session, table_name, file_name, copy_params, row_desc, create_params):
3042 self._oprot.writeMessageBegin(
'import_geo_table', TMessageType.CALL, self.
_seqid)
3044 args.session = session
3045 args.table_name = table_name
3046 args.file_name = file_name
3047 args.copy_params = copy_params
3048 args.row_desc = row_desc
3049 args.create_params = create_params
3051 self._oprot.writeMessageEnd()
3052 self._oprot.trans.flush()
3056 (fname, mtype, rseqid) = iprot.readMessageBegin()
3057 if mtype == TMessageType.EXCEPTION:
3058 x = TApplicationException()
3060 iprot.readMessageEnd()
3064 iprot.readMessageEnd()
3065 if result.e
is not None:
3080 self._oprot.writeMessageBegin(
'import_table_status', TMessageType.CALL, self.
_seqid)
3082 args.session = session
3083 args.import_id = import_id
3085 self._oprot.writeMessageEnd()
3086 self._oprot.trans.flush()
3090 (fname, mtype, rseqid) = iprot.readMessageBegin()
3091 if mtype == TMessageType.EXCEPTION:
3092 x = TApplicationException()
3094 iprot.readMessageEnd()
3098 iprot.readMessageEnd()
3099 if result.success
is not None:
3100 return result.success
3101 if result.e
is not None:
3103 raise TApplicationException(TApplicationException.MISSING_RESULT,
"import_table_status failed: unknown result")
3117 self._oprot.writeMessageBegin(
'get_first_geo_file_in_archive', TMessageType.CALL, self.
_seqid)
3119 args.session = session
3120 args.archive_path = archive_path
3121 args.copy_params = copy_params
3123 self._oprot.writeMessageEnd()
3124 self._oprot.trans.flush()
3128 (fname, mtype, rseqid) = iprot.readMessageBegin()
3129 if mtype == TMessageType.EXCEPTION:
3130 x = TApplicationException()
3132 iprot.readMessageEnd()
3136 iprot.readMessageEnd()
3137 if result.success
is not None:
3138 return result.success
3139 if result.e
is not None:
3141 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_first_geo_file_in_archive failed: unknown result")
3155 self._oprot.writeMessageBegin(
'get_all_files_in_archive', TMessageType.CALL, self.
_seqid)
3157 args.session = session
3158 args.archive_path = archive_path
3159 args.copy_params = copy_params
3161 self._oprot.writeMessageEnd()
3162 self._oprot.trans.flush()
3166 (fname, mtype, rseqid) = iprot.readMessageBegin()
3167 if mtype == TMessageType.EXCEPTION:
3168 x = TApplicationException()
3170 iprot.readMessageEnd()
3174 iprot.readMessageEnd()
3175 if result.success
is not None:
3176 return result.success
3177 if result.e
is not None:
3179 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_all_files_in_archive failed: unknown result")
3193 self._oprot.writeMessageBegin(
'get_layers_in_geo_file', TMessageType.CALL, self.
_seqid)
3195 args.session = session
3196 args.file_name = file_name
3197 args.copy_params = copy_params
3199 self._oprot.writeMessageEnd()
3200 self._oprot.trans.flush()
3204 (fname, mtype, rseqid) = iprot.readMessageBegin()
3205 if mtype == TMessageType.EXCEPTION:
3206 x = TApplicationException()
3208 iprot.readMessageEnd()
3212 iprot.readMessageEnd()
3213 if result.success
is not None:
3214 return result.success
3215 if result.e
is not None:
3217 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_layers_in_geo_file failed: unknown result")
3230 self._oprot.writeMessageBegin(
'query_get_outer_fragment_count', TMessageType.CALL, self.
_seqid)
3232 args.session = session
3235 self._oprot.writeMessageEnd()
3236 self._oprot.trans.flush()
3240 (fname, mtype, rseqid) = iprot.readMessageBegin()
3241 if mtype == TMessageType.EXCEPTION:
3242 x = TApplicationException()
3244 iprot.readMessageEnd()
3248 iprot.readMessageEnd()
3249 if result.success
is not None:
3250 return result.success
3251 if result.e
is not None:
3253 raise TApplicationException(TApplicationException.MISSING_RESULT,
"query_get_outer_fragment_count failed: unknown result")
3266 self._oprot.writeMessageBegin(
'check_table_consistency', TMessageType.CALL, self.
_seqid)
3268 args.session = session
3269 args.table_id = table_id
3271 self._oprot.writeMessageEnd()
3272 self._oprot.trans.flush()
3276 (fname, mtype, rseqid) = iprot.readMessageBegin()
3277 if mtype == TMessageType.EXCEPTION:
3278 x = TApplicationException()
3280 iprot.readMessageEnd()
3284 iprot.readMessageEnd()
3285 if result.success
is not None:
3286 return result.success
3287 if result.e
is not None:
3289 raise TApplicationException(TApplicationException.MISSING_RESULT,
"check_table_consistency failed: unknown result")
3291 def start_query(self, leaf_session, parent_session, query_ra, just_explain, outer_fragment_indices):
3298 - outer_fragment_indices
3301 self.
send_start_query(leaf_session, parent_session, query_ra, just_explain, outer_fragment_indices)
3304 def send_start_query(self, leaf_session, parent_session, query_ra, just_explain, outer_fragment_indices):
3305 self._oprot.writeMessageBegin(
'start_query', TMessageType.CALL, self.
_seqid)
3307 args.leaf_session = leaf_session
3308 args.parent_session = parent_session
3309 args.query_ra = query_ra
3310 args.just_explain = just_explain
3311 args.outer_fragment_indices = outer_fragment_indices
3313 self._oprot.writeMessageEnd()
3314 self._oprot.trans.flush()
3318 (fname, mtype, rseqid) = iprot.readMessageBegin()
3319 if mtype == TMessageType.EXCEPTION:
3320 x = TApplicationException()
3322 iprot.readMessageEnd()
3326 iprot.readMessageEnd()
3327 if result.success
is not None:
3328 return result.success
3329 if result.e
is not None:
3331 raise TApplicationException(TApplicationException.MISSING_RESULT,
"start_query failed: unknown result")
3344 self._oprot.writeMessageBegin(
'execute_query_step', TMessageType.CALL, self.
_seqid)
3346 args.pending_query = pending_query
3347 args.subquery_id = subquery_id
3349 self._oprot.writeMessageEnd()
3350 self._oprot.trans.flush()
3354 (fname, mtype, rseqid) = iprot.readMessageBegin()
3355 if mtype == TMessageType.EXCEPTION:
3356 x = TApplicationException()
3358 iprot.readMessageEnd()
3362 iprot.readMessageEnd()
3363 if result.success
is not None:
3364 return result.success
3365 if result.e
is not None:
3367 raise TApplicationException(TApplicationException.MISSING_RESULT,
"execute_query_step failed: unknown result")
3376 - is_final_subquery_result
3383 self._oprot.writeMessageBegin(
'broadcast_serialized_rows', TMessageType.CALL, self.
_seqid)
3385 args.serialized_rows = serialized_rows
3386 args.row_desc = row_desc
3387 args.query_id = query_id
3388 args.subquery_id = subquery_id
3389 args.is_final_subquery_result = is_final_subquery_result
3391 self._oprot.writeMessageEnd()
3392 self._oprot.trans.flush()
3396 (fname, mtype, rseqid) = iprot.readMessageBegin()
3397 if mtype == TMessageType.EXCEPTION:
3398 x = TApplicationException()
3400 iprot.readMessageEnd()
3404 iprot.readMessageEnd()
3405 if result.e
is not None:
3422 self._oprot.writeMessageBegin(
'start_render_query', TMessageType.CALL, self.
_seqid)
3424 args.session = session
3425 args.widget_id = widget_id
3426 args.node_idx = node_idx
3427 args.vega_json = vega_json
3429 self._oprot.writeMessageEnd()
3430 self._oprot.trans.flush()
3434 (fname, mtype, rseqid) = iprot.readMessageBegin()
3435 if mtype == TMessageType.EXCEPTION:
3436 x = TApplicationException()
3438 iprot.readMessageEnd()
3442 iprot.readMessageEnd()
3443 if result.success
is not None:
3444 return result.success
3445 if result.e
is not None:
3447 raise TApplicationException(TApplicationException.MISSING_RESULT,
"start_render_query failed: unknown result")
3460 self._oprot.writeMessageBegin(
'execute_next_render_step', TMessageType.CALL, self.
_seqid)
3462 args.pending_render = pending_render
3463 args.merged_data = merged_data
3465 self._oprot.writeMessageEnd()
3466 self._oprot.trans.flush()
3470 (fname, mtype, rseqid) = iprot.readMessageBegin()
3471 if mtype == TMessageType.EXCEPTION:
3472 x = TApplicationException()
3474 iprot.readMessageEnd()
3478 iprot.readMessageEnd()
3479 if result.success
is not None:
3480 return result.success
3481 if result.e
is not None:
3483 raise TApplicationException(TApplicationException.MISSING_RESULT,
"execute_next_render_step failed: unknown result")
3496 self._oprot.writeMessageBegin(
'insert_data', TMessageType.CALL, self.
_seqid)
3498 args.session = session
3499 args.insert_data = insert_data
3501 self._oprot.writeMessageEnd()
3502 self._oprot.trans.flush()
3506 (fname, mtype, rseqid) = iprot.readMessageBegin()
3507 if mtype == TMessageType.EXCEPTION:
3508 x = TApplicationException()
3510 iprot.readMessageEnd()
3514 iprot.readMessageEnd()
3515 if result.e
is not None:
3530 self._oprot.writeMessageBegin(
'checkpoint', TMessageType.CALL, self.
_seqid)
3532 args.session = session
3533 args.table_id = table_id
3535 self._oprot.writeMessageEnd()
3536 self._oprot.trans.flush()
3540 (fname, mtype, rseqid) = iprot.readMessageBegin()
3541 if mtype == TMessageType.EXCEPTION:
3542 x = TApplicationException()
3544 iprot.readMessageEnd()
3548 iprot.readMessageEnd()
3549 if result.e
is not None:
3563 self._oprot.writeMessageBegin(
'get_roles', TMessageType.CALL, self.
_seqid)
3565 args.session = session
3567 self._oprot.writeMessageEnd()
3568 self._oprot.trans.flush()
3572 (fname, mtype, rseqid) = iprot.readMessageBegin()
3573 if mtype == TMessageType.EXCEPTION:
3574 x = TApplicationException()
3576 iprot.readMessageEnd()
3580 iprot.readMessageEnd()
3581 if result.success
is not None:
3582 return result.success
3583 if result.e
is not None:
3585 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_roles failed: unknown result")
3598 self._oprot.writeMessageBegin(
'get_db_objects_for_grantee', TMessageType.CALL, self.
_seqid)
3600 args.session = session
3601 args.roleName = roleName
3603 self._oprot.writeMessageEnd()
3604 self._oprot.trans.flush()
3608 (fname, mtype, rseqid) = iprot.readMessageBegin()
3609 if mtype == TMessageType.EXCEPTION:
3610 x = TApplicationException()
3612 iprot.readMessageEnd()
3616 iprot.readMessageEnd()
3617 if result.success
is not None:
3618 return result.success
3619 if result.e
is not None:
3621 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_db_objects_for_grantee failed: unknown result")
3635 self._oprot.writeMessageBegin(
'get_db_object_privs', TMessageType.CALL, self.
_seqid)
3637 args.session = session
3638 args.objectName = objectName
3641 self._oprot.writeMessageEnd()
3642 self._oprot.trans.flush()
3646 (fname, mtype, rseqid) = iprot.readMessageBegin()
3647 if mtype == TMessageType.EXCEPTION:
3648 x = TApplicationException()
3650 iprot.readMessageEnd()
3654 iprot.readMessageEnd()
3655 if result.success
is not None:
3656 return result.success
3657 if result.e
is not None:
3659 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_db_object_privs failed: unknown result")
3672 self._oprot.writeMessageBegin(
'get_all_roles_for_user', TMessageType.CALL, self.
_seqid)
3674 args.session = session
3675 args.userName = userName
3677 self._oprot.writeMessageEnd()
3678 self._oprot.trans.flush()
3682 (fname, mtype, rseqid) = iprot.readMessageBegin()
3683 if mtype == TMessageType.EXCEPTION:
3684 x = TApplicationException()
3686 iprot.readMessageEnd()
3690 iprot.readMessageEnd()
3691 if result.success
is not None:
3692 return result.success
3693 if result.e
is not None:
3695 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_all_roles_for_user failed: unknown result")
3709 self._oprot.writeMessageBegin(
'has_role', TMessageType.CALL, self.
_seqid)
3711 args.session = session
3712 args.granteeName = granteeName
3713 args.roleName = roleName
3715 self._oprot.writeMessageEnd()
3716 self._oprot.trans.flush()
3720 (fname, mtype, rseqid) = iprot.readMessageBegin()
3721 if mtype == TMessageType.EXCEPTION:
3722 x = TApplicationException()
3724 iprot.readMessageEnd()
3728 iprot.readMessageEnd()
3729 if result.success
is not None:
3730 return result.success
3731 if result.e
is not None:
3733 raise TApplicationException(TApplicationException.MISSING_RESULT,
"has_role failed: unknown result")
3749 self._oprot.writeMessageBegin(
'has_object_privilege', TMessageType.CALL, self.
_seqid)
3751 args.session = session
3752 args.granteeName = granteeName
3753 args.ObjectName = ObjectName
3754 args.objectType = objectType
3755 args.permissions = permissions
3757 self._oprot.writeMessageEnd()
3758 self._oprot.trans.flush()
3762 (fname, mtype, rseqid) = iprot.readMessageBegin()
3763 if mtype == TMessageType.EXCEPTION:
3764 x = TApplicationException()
3766 iprot.readMessageEnd()
3770 iprot.readMessageEnd()
3771 if result.success
is not None:
3772 return result.success
3773 if result.e
is not None:
3775 raise TApplicationException(TApplicationException.MISSING_RESULT,
"has_object_privilege failed: unknown result")
3789 self._oprot.writeMessageBegin(
'set_license_key', TMessageType.CALL, self.
_seqid)
3791 args.session = session
3795 self._oprot.writeMessageEnd()
3796 self._oprot.trans.flush()
3800 (fname, mtype, rseqid) = iprot.readMessageBegin()
3801 if mtype == TMessageType.EXCEPTION:
3802 x = TApplicationException()
3804 iprot.readMessageEnd()
3808 iprot.readMessageEnd()
3809 if result.success
is not None:
3810 return result.success
3811 if result.e
is not None:
3813 raise TApplicationException(TApplicationException.MISSING_RESULT,
"set_license_key failed: unknown result")
3826 self._oprot.writeMessageBegin(
'get_license_claims', TMessageType.CALL, self.
_seqid)
3828 args.session = session
3831 self._oprot.writeMessageEnd()
3832 self._oprot.trans.flush()
3836 (fname, mtype, rseqid) = iprot.readMessageBegin()
3837 if mtype == TMessageType.EXCEPTION:
3838 x = TApplicationException()
3840 iprot.readMessageEnd()
3844 iprot.readMessageEnd()
3845 if result.success
is not None:
3846 return result.success
3847 if result.e
is not None:
3849 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_license_claims failed: unknown result")
3861 self._oprot.writeMessageBegin(
'get_device_parameters', TMessageType.CALL, self.
_seqid)
3863 args.session = session
3865 self._oprot.writeMessageEnd()
3866 self._oprot.trans.flush()
3870 (fname, mtype, rseqid) = iprot.readMessageBegin()
3871 if mtype == TMessageType.EXCEPTION:
3872 x = TApplicationException()
3874 iprot.readMessageEnd()
3878 iprot.readMessageEnd()
3879 if result.success
is not None:
3880 return result.success
3881 if result.e
is not None:
3883 raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_device_parameters failed: unknown result")
3898 self._oprot.writeMessageBegin(
'register_runtime_extension_functions', TMessageType.CALL, self.
_seqid)
3900 args.session = session
3903 args.device_ir_map = device_ir_map
3905 self._oprot.writeMessageEnd()
3906 self._oprot.trans.flush()
3910 (fname, mtype, rseqid) = iprot.readMessageBegin()
3911 if mtype == TMessageType.EXCEPTION:
3912 x = TApplicationException()
3914 iprot.readMessageEnd()
3918 iprot.readMessageEnd()
3919 if result.e
is not None:
3928 self.
_processMap[
"connect"] = Processor.process_connect
3929 self.
_processMap[
"krb5_connect"] = Processor.process_krb5_connect
3930 self.
_processMap[
"disconnect"] = Processor.process_disconnect
3931 self.
_processMap[
"switch_database"] = Processor.process_switch_database
3932 self.
_processMap[
"clone_session"] = Processor.process_clone_session
3933 self.
_processMap[
"get_server_status"] = Processor.process_get_server_status
3934 self.
_processMap[
"get_status"] = Processor.process_get_status
3935 self.
_processMap[
"get_hardware_info"] = Processor.process_get_hardware_info
3936 self.
_processMap[
"get_tables"] = Processor.process_get_tables
3937 self.
_processMap[
"get_physical_tables"] = Processor.process_get_physical_tables
3938 self.
_processMap[
"get_views"] = Processor.process_get_views
3939 self.
_processMap[
"get_tables_meta"] = Processor.process_get_tables_meta
3940 self.
_processMap[
"get_table_details"] = Processor.process_get_table_details
3941 self.
_processMap[
"get_internal_table_details"] = Processor.process_get_internal_table_details
3942 self.
_processMap[
"get_users"] = Processor.process_get_users
3943 self.
_processMap[
"get_databases"] = Processor.process_get_databases
3944 self.
_processMap[
"get_version"] = Processor.process_get_version
3945 self.
_processMap[
"start_heap_profile"] = Processor.process_start_heap_profile
3946 self.
_processMap[
"stop_heap_profile"] = Processor.process_stop_heap_profile
3947 self.
_processMap[
"get_heap_profile"] = Processor.process_get_heap_profile
3948 self.
_processMap[
"get_memory"] = Processor.process_get_memory
3949 self.
_processMap[
"clear_cpu_memory"] = Processor.process_clear_cpu_memory
3950 self.
_processMap[
"clear_gpu_memory"] = Processor.process_clear_gpu_memory
3951 self.
_processMap[
"set_table_epoch"] = Processor.process_set_table_epoch
3952 self.
_processMap[
"set_table_epoch_by_name"] = Processor.process_set_table_epoch_by_name
3953 self.
_processMap[
"get_table_epoch"] = Processor.process_get_table_epoch
3954 self.
_processMap[
"get_table_epoch_by_name"] = Processor.process_get_table_epoch_by_name
3955 self.
_processMap[
"get_table_epochs"] = Processor.process_get_table_epochs
3956 self.
_processMap[
"set_table_epochs"] = Processor.process_set_table_epochs
3957 self.
_processMap[
"get_session_info"] = Processor.process_get_session_info
3958 self.
_processMap[
"sql_execute"] = Processor.process_sql_execute
3959 self.
_processMap[
"sql_execute_df"] = Processor.process_sql_execute_df
3960 self.
_processMap[
"sql_execute_gdf"] = Processor.process_sql_execute_gdf
3961 self.
_processMap[
"deallocate_df"] = Processor.process_deallocate_df
3962 self.
_processMap[
"interrupt"] = Processor.process_interrupt
3963 self.
_processMap[
"sql_validate"] = Processor.process_sql_validate
3964 self.
_processMap[
"get_completion_hints"] = Processor.process_get_completion_hints
3965 self.
_processMap[
"set_execution_mode"] = Processor.process_set_execution_mode
3966 self.
_processMap[
"render_vega"] = Processor.process_render_vega
3967 self.
_processMap[
"get_result_row_for_pixel"] = Processor.process_get_result_row_for_pixel
3968 self.
_processMap[
"get_dashboard"] = Processor.process_get_dashboard
3969 self.
_processMap[
"get_dashboards"] = Processor.process_get_dashboards
3970 self.
_processMap[
"create_dashboard"] = Processor.process_create_dashboard
3971 self.
_processMap[
"replace_dashboard"] = Processor.process_replace_dashboard
3972 self.
_processMap[
"delete_dashboard"] = Processor.process_delete_dashboard
3973 self.
_processMap[
"share_dashboards"] = Processor.process_share_dashboards
3974 self.
_processMap[
"delete_dashboards"] = Processor.process_delete_dashboards
3975 self.
_processMap[
"share_dashboard"] = Processor.process_share_dashboard
3976 self.
_processMap[
"unshare_dashboard"] = Processor.process_unshare_dashboard
3977 self.
_processMap[
"unshare_dashboards"] = Processor.process_unshare_dashboards
3978 self.
_processMap[
"get_dashboard_grantees"] = Processor.process_get_dashboard_grantees
3979 self.
_processMap[
"get_link_view"] = Processor.process_get_link_view
3980 self.
_processMap[
"create_link"] = Processor.process_create_link
3981 self.
_processMap[
"load_table_binary"] = Processor.process_load_table_binary
3982 self.
_processMap[
"load_table_binary_columnar"] = Processor.process_load_table_binary_columnar
3983 self.
_processMap[
"load_table_binary_arrow"] = Processor.process_load_table_binary_arrow
3984 self.
_processMap[
"load_table"] = Processor.process_load_table
3985 self.
_processMap[
"detect_column_types"] = Processor.process_detect_column_types
3986 self.
_processMap[
"create_table"] = Processor.process_create_table
3987 self.
_processMap[
"import_table"] = Processor.process_import_table
3988 self.
_processMap[
"import_geo_table"] = Processor.process_import_geo_table
3989 self.
_processMap[
"import_table_status"] = Processor.process_import_table_status
3990 self.
_processMap[
"get_first_geo_file_in_archive"] = Processor.process_get_first_geo_file_in_archive
3991 self.
_processMap[
"get_all_files_in_archive"] = Processor.process_get_all_files_in_archive
3992 self.
_processMap[
"get_layers_in_geo_file"] = Processor.process_get_layers_in_geo_file
3993 self.
_processMap[
"query_get_outer_fragment_count"] = Processor.process_query_get_outer_fragment_count
3994 self.
_processMap[
"check_table_consistency"] = Processor.process_check_table_consistency
3995 self.
_processMap[
"start_query"] = Processor.process_start_query
3996 self.
_processMap[
"execute_query_step"] = Processor.process_execute_query_step
3997 self.
_processMap[
"broadcast_serialized_rows"] = Processor.process_broadcast_serialized_rows
3998 self.
_processMap[
"start_render_query"] = Processor.process_start_render_query
3999 self.
_processMap[
"execute_next_render_step"] = Processor.process_execute_next_render_step
4000 self.
_processMap[
"insert_data"] = Processor.process_insert_data
4001 self.
_processMap[
"checkpoint"] = Processor.process_checkpoint
4002 self.
_processMap[
"get_roles"] = Processor.process_get_roles
4003 self.
_processMap[
"get_db_objects_for_grantee"] = Processor.process_get_db_objects_for_grantee
4004 self.
_processMap[
"get_db_object_privs"] = Processor.process_get_db_object_privs
4005 self.
_processMap[
"get_all_roles_for_user"] = Processor.process_get_all_roles_for_user
4006 self.
_processMap[
"has_role"] = Processor.process_has_role
4007 self.
_processMap[
"has_object_privilege"] = Processor.process_has_object_privilege
4008 self.
_processMap[
"set_license_key"] = Processor.process_set_license_key
4009 self.
_processMap[
"get_license_claims"] = Processor.process_get_license_claims
4010 self.
_processMap[
"get_device_parameters"] = Processor.process_get_device_parameters
4011 self.
_processMap[
"register_runtime_extension_functions"] = Processor.process_register_runtime_extension_functions
4018 (name, type, seqid) = iprot.readMessageBegin()
4022 iprot.skip(TType.STRUCT)
4023 iprot.readMessageEnd()
4024 x = TApplicationException(TApplicationException.UNKNOWN_METHOD,
'Unknown function %s' % (name))
4025 oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
4027 oprot.writeMessageEnd()
4037 iprot.readMessageEnd()
4040 result.success = self._handler.connect(args.user, args.passwd, args.dbname)
4041 msg_type = TMessageType.REPLY
4042 except TTransport.TTransportException:
4044 except TOmniSciException
as e:
4045 msg_type = TMessageType.REPLY
4047 except TApplicationException
as ex:
4048 logging.exception(
'TApplication exception in handler')
4049 msg_type = TMessageType.EXCEPTION
4052 logging.exception(
'Unexpected exception in handler')
4053 msg_type = TMessageType.EXCEPTION
4054 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4055 oprot.writeMessageBegin(
"connect", msg_type, seqid)
4057 oprot.writeMessageEnd()
4063 iprot.readMessageEnd()
4066 result.success = self._handler.krb5_connect(args.inputToken, args.dbname)
4067 msg_type = TMessageType.REPLY
4068 except TTransport.TTransportException:
4070 except TOmniSciException
as e:
4071 msg_type = TMessageType.REPLY
4073 except TApplicationException
as ex:
4074 logging.exception(
'TApplication exception in handler')
4075 msg_type = TMessageType.EXCEPTION
4078 logging.exception(
'Unexpected exception in handler')
4079 msg_type = TMessageType.EXCEPTION
4080 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4081 oprot.writeMessageBegin(
"krb5_connect", msg_type, seqid)
4083 oprot.writeMessageEnd()
4089 iprot.readMessageEnd()
4092 self._handler.disconnect(args.session)
4093 msg_type = TMessageType.REPLY
4094 except TTransport.TTransportException:
4096 except TOmniSciException
as e:
4097 msg_type = TMessageType.REPLY
4099 except TApplicationException
as ex:
4100 logging.exception(
'TApplication exception in handler')
4101 msg_type = TMessageType.EXCEPTION
4104 logging.exception(
'Unexpected exception in handler')
4105 msg_type = TMessageType.EXCEPTION
4106 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4107 oprot.writeMessageBegin(
"disconnect", msg_type, seqid)
4109 oprot.writeMessageEnd()
4115 iprot.readMessageEnd()
4118 self._handler.switch_database(args.session, args.dbname)
4119 msg_type = TMessageType.REPLY
4120 except TTransport.TTransportException:
4122 except TOmniSciException
as e:
4123 msg_type = TMessageType.REPLY
4125 except TApplicationException
as ex:
4126 logging.exception(
'TApplication exception in handler')
4127 msg_type = TMessageType.EXCEPTION
4130 logging.exception(
'Unexpected exception in handler')
4131 msg_type = TMessageType.EXCEPTION
4132 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4133 oprot.writeMessageBegin(
"switch_database", msg_type, seqid)
4135 oprot.writeMessageEnd()
4141 iprot.readMessageEnd()
4144 result.success = self._handler.clone_session(args.session)
4145 msg_type = TMessageType.REPLY
4146 except TTransport.TTransportException:
4148 except TOmniSciException
as e:
4149 msg_type = TMessageType.REPLY
4151 except TApplicationException
as ex:
4152 logging.exception(
'TApplication exception in handler')
4153 msg_type = TMessageType.EXCEPTION
4156 logging.exception(
'Unexpected exception in handler')
4157 msg_type = TMessageType.EXCEPTION
4158 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4159 oprot.writeMessageBegin(
"clone_session", msg_type, seqid)
4161 oprot.writeMessageEnd()
4167 iprot.readMessageEnd()
4170 result.success = self._handler.get_server_status(args.session)
4171 msg_type = TMessageType.REPLY
4172 except TTransport.TTransportException:
4174 except TOmniSciException
as e:
4175 msg_type = TMessageType.REPLY
4177 except TApplicationException
as ex:
4178 logging.exception(
'TApplication exception in handler')
4179 msg_type = TMessageType.EXCEPTION
4182 logging.exception(
'Unexpected exception in handler')
4183 msg_type = TMessageType.EXCEPTION
4184 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4185 oprot.writeMessageBegin(
"get_server_status", msg_type, seqid)
4187 oprot.writeMessageEnd()
4193 iprot.readMessageEnd()
4196 result.success = self._handler.get_status(args.session)
4197 msg_type = TMessageType.REPLY
4198 except TTransport.TTransportException:
4200 except TOmniSciException
as e:
4201 msg_type = TMessageType.REPLY
4203 except TApplicationException
as ex:
4204 logging.exception(
'TApplication exception in handler')
4205 msg_type = TMessageType.EXCEPTION
4208 logging.exception(
'Unexpected exception in handler')
4209 msg_type = TMessageType.EXCEPTION
4210 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4211 oprot.writeMessageBegin(
"get_status", msg_type, seqid)
4213 oprot.writeMessageEnd()
4219 iprot.readMessageEnd()
4222 result.success = self._handler.get_hardware_info(args.session)
4223 msg_type = TMessageType.REPLY
4224 except TTransport.TTransportException:
4226 except TOmniSciException
as e:
4227 msg_type = TMessageType.REPLY
4229 except TApplicationException
as ex:
4230 logging.exception(
'TApplication exception in handler')
4231 msg_type = TMessageType.EXCEPTION
4234 logging.exception(
'Unexpected exception in handler')
4235 msg_type = TMessageType.EXCEPTION
4236 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4237 oprot.writeMessageBegin(
"get_hardware_info", msg_type, seqid)
4239 oprot.writeMessageEnd()
4245 iprot.readMessageEnd()
4248 result.success = self._handler.get_tables(args.session)
4249 msg_type = TMessageType.REPLY
4250 except TTransport.TTransportException:
4252 except TOmniSciException
as e:
4253 msg_type = TMessageType.REPLY
4255 except TApplicationException
as ex:
4256 logging.exception(
'TApplication exception in handler')
4257 msg_type = TMessageType.EXCEPTION
4260 logging.exception(
'Unexpected exception in handler')
4261 msg_type = TMessageType.EXCEPTION
4262 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4263 oprot.writeMessageBegin(
"get_tables", msg_type, seqid)
4265 oprot.writeMessageEnd()
4271 iprot.readMessageEnd()
4274 result.success = self._handler.get_physical_tables(args.session)
4275 msg_type = TMessageType.REPLY
4276 except TTransport.TTransportException:
4278 except TOmniSciException
as e:
4279 msg_type = TMessageType.REPLY
4281 except TApplicationException
as ex:
4282 logging.exception(
'TApplication exception in handler')
4283 msg_type = TMessageType.EXCEPTION
4286 logging.exception(
'Unexpected exception in handler')
4287 msg_type = TMessageType.EXCEPTION
4288 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4289 oprot.writeMessageBegin(
"get_physical_tables", msg_type, seqid)
4291 oprot.writeMessageEnd()
4297 iprot.readMessageEnd()
4300 result.success = self._handler.get_views(args.session)
4301 msg_type = TMessageType.REPLY
4302 except TTransport.TTransportException:
4304 except TOmniSciException
as e:
4305 msg_type = TMessageType.REPLY
4307 except TApplicationException
as ex:
4308 logging.exception(
'TApplication exception in handler')
4309 msg_type = TMessageType.EXCEPTION
4312 logging.exception(
'Unexpected exception in handler')
4313 msg_type = TMessageType.EXCEPTION
4314 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4315 oprot.writeMessageBegin(
"get_views", msg_type, seqid)
4317 oprot.writeMessageEnd()
4323 iprot.readMessageEnd()
4326 result.success = self._handler.get_tables_meta(args.session)
4327 msg_type = TMessageType.REPLY
4328 except TTransport.TTransportException:
4330 except TOmniSciException
as e:
4331 msg_type = TMessageType.REPLY
4333 except TApplicationException
as ex:
4334 logging.exception(
'TApplication exception in handler')
4335 msg_type = TMessageType.EXCEPTION
4338 logging.exception(
'Unexpected exception in handler')
4339 msg_type = TMessageType.EXCEPTION
4340 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4341 oprot.writeMessageBegin(
"get_tables_meta", msg_type, seqid)
4343 oprot.writeMessageEnd()
4349 iprot.readMessageEnd()
4352 result.success = self._handler.get_table_details(args.session, args.table_name)
4353 msg_type = TMessageType.REPLY
4354 except TTransport.TTransportException:
4356 except TOmniSciException
as e:
4357 msg_type = TMessageType.REPLY
4359 except TApplicationException
as ex:
4360 logging.exception(
'TApplication exception in handler')
4361 msg_type = TMessageType.EXCEPTION
4364 logging.exception(
'Unexpected exception in handler')
4365 msg_type = TMessageType.EXCEPTION
4366 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4367 oprot.writeMessageBegin(
"get_table_details", msg_type, seqid)
4369 oprot.writeMessageEnd()
4375 iprot.readMessageEnd()
4378 result.success = self._handler.get_internal_table_details(args.session, args.table_name)
4379 msg_type = TMessageType.REPLY
4380 except TTransport.TTransportException:
4382 except TOmniSciException
as e:
4383 msg_type = TMessageType.REPLY
4385 except TApplicationException
as ex:
4386 logging.exception(
'TApplication exception in handler')
4387 msg_type = TMessageType.EXCEPTION
4390 logging.exception(
'Unexpected exception in handler')
4391 msg_type = TMessageType.EXCEPTION
4392 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4393 oprot.writeMessageBegin(
"get_internal_table_details", msg_type, seqid)
4395 oprot.writeMessageEnd()
4401 iprot.readMessageEnd()
4404 result.success = self._handler.get_users(args.session)
4405 msg_type = TMessageType.REPLY
4406 except TTransport.TTransportException:
4408 except TOmniSciException
as e:
4409 msg_type = TMessageType.REPLY
4411 except TApplicationException
as ex:
4412 logging.exception(
'TApplication exception in handler')
4413 msg_type = TMessageType.EXCEPTION
4416 logging.exception(
'Unexpected exception in handler')
4417 msg_type = TMessageType.EXCEPTION
4418 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4419 oprot.writeMessageBegin(
"get_users", msg_type, seqid)
4421 oprot.writeMessageEnd()
4427 iprot.readMessageEnd()
4430 result.success = self._handler.get_databases(args.session)
4431 msg_type = TMessageType.REPLY
4432 except TTransport.TTransportException:
4434 except TOmniSciException
as e:
4435 msg_type = TMessageType.REPLY
4437 except TApplicationException
as ex:
4438 logging.exception(
'TApplication exception in handler')
4439 msg_type = TMessageType.EXCEPTION
4442 logging.exception(
'Unexpected exception in handler')
4443 msg_type = TMessageType.EXCEPTION
4444 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4445 oprot.writeMessageBegin(
"get_databases", msg_type, seqid)
4447 oprot.writeMessageEnd()
4453 iprot.readMessageEnd()
4456 result.success = self._handler.get_version()
4457 msg_type = TMessageType.REPLY
4458 except TTransport.TTransportException:
4460 except TOmniSciException
as e:
4461 msg_type = TMessageType.REPLY
4463 except TApplicationException
as ex:
4464 logging.exception(
'TApplication exception in handler')
4465 msg_type = TMessageType.EXCEPTION
4468 logging.exception(
'Unexpected exception in handler')
4469 msg_type = TMessageType.EXCEPTION
4470 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4471 oprot.writeMessageBegin(
"get_version", msg_type, seqid)
4473 oprot.writeMessageEnd()
4479 iprot.readMessageEnd()
4482 self._handler.start_heap_profile(args.session)
4483 msg_type = TMessageType.REPLY
4484 except TTransport.TTransportException:
4486 except TOmniSciException
as e:
4487 msg_type = TMessageType.REPLY
4489 except TApplicationException
as ex:
4490 logging.exception(
'TApplication exception in handler')
4491 msg_type = TMessageType.EXCEPTION
4494 logging.exception(
'Unexpected exception in handler')
4495 msg_type = TMessageType.EXCEPTION
4496 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4497 oprot.writeMessageBegin(
"start_heap_profile", msg_type, seqid)
4499 oprot.writeMessageEnd()
4505 iprot.readMessageEnd()
4508 self._handler.stop_heap_profile(args.session)
4509 msg_type = TMessageType.REPLY
4510 except TTransport.TTransportException:
4512 except TOmniSciException
as e:
4513 msg_type = TMessageType.REPLY
4515 except TApplicationException
as ex:
4516 logging.exception(
'TApplication exception in handler')
4517 msg_type = TMessageType.EXCEPTION
4520 logging.exception(
'Unexpected exception in handler')
4521 msg_type = TMessageType.EXCEPTION
4522 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4523 oprot.writeMessageBegin(
"stop_heap_profile", msg_type, seqid)
4525 oprot.writeMessageEnd()
4531 iprot.readMessageEnd()
4534 result.success = self._handler.get_heap_profile(args.session)
4535 msg_type = TMessageType.REPLY
4536 except TTransport.TTransportException:
4538 except TOmniSciException
as e:
4539 msg_type = TMessageType.REPLY
4541 except TApplicationException
as ex:
4542 logging.exception(
'TApplication exception in handler')
4543 msg_type = TMessageType.EXCEPTION
4546 logging.exception(
'Unexpected exception in handler')
4547 msg_type = TMessageType.EXCEPTION
4548 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4549 oprot.writeMessageBegin(
"get_heap_profile", msg_type, seqid)
4551 oprot.writeMessageEnd()
4557 iprot.readMessageEnd()
4560 result.success = self._handler.get_memory(args.session, args.memory_level)
4561 msg_type = TMessageType.REPLY
4562 except TTransport.TTransportException:
4564 except TOmniSciException
as e:
4565 msg_type = TMessageType.REPLY
4567 except TApplicationException
as ex:
4568 logging.exception(
'TApplication exception in handler')
4569 msg_type = TMessageType.EXCEPTION
4572 logging.exception(
'Unexpected exception in handler')
4573 msg_type = TMessageType.EXCEPTION
4574 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4575 oprot.writeMessageBegin(
"get_memory", msg_type, seqid)
4577 oprot.writeMessageEnd()
4583 iprot.readMessageEnd()
4586 self._handler.clear_cpu_memory(args.session)
4587 msg_type = TMessageType.REPLY
4588 except TTransport.TTransportException:
4590 except TOmniSciException
as e:
4591 msg_type = TMessageType.REPLY
4593 except TApplicationException
as ex:
4594 logging.exception(
'TApplication exception in handler')
4595 msg_type = TMessageType.EXCEPTION
4598 logging.exception(
'Unexpected exception in handler')
4599 msg_type = TMessageType.EXCEPTION
4600 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4601 oprot.writeMessageBegin(
"clear_cpu_memory", msg_type, seqid)
4603 oprot.writeMessageEnd()
4609 iprot.readMessageEnd()
4612 self._handler.clear_gpu_memory(args.session)
4613 msg_type = TMessageType.REPLY
4614 except TTransport.TTransportException:
4616 except TOmniSciException
as e:
4617 msg_type = TMessageType.REPLY
4619 except TApplicationException
as ex:
4620 logging.exception(
'TApplication exception in handler')
4621 msg_type = TMessageType.EXCEPTION
4624 logging.exception(
'Unexpected exception in handler')
4625 msg_type = TMessageType.EXCEPTION
4626 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4627 oprot.writeMessageBegin(
"clear_gpu_memory", msg_type, seqid)
4629 oprot.writeMessageEnd()
4635 iprot.readMessageEnd()
4638 self._handler.set_table_epoch(args.session, args.db_id, args.table_id, args.new_epoch)
4639 msg_type = TMessageType.REPLY
4640 except TTransport.TTransportException:
4642 except TOmniSciException
as e:
4643 msg_type = TMessageType.REPLY
4645 except TApplicationException
as ex:
4646 logging.exception(
'TApplication exception in handler')
4647 msg_type = TMessageType.EXCEPTION
4650 logging.exception(
'Unexpected exception in handler')
4651 msg_type = TMessageType.EXCEPTION
4652 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4653 oprot.writeMessageBegin(
"set_table_epoch", msg_type, seqid)
4655 oprot.writeMessageEnd()
4661 iprot.readMessageEnd()
4664 self._handler.set_table_epoch_by_name(args.session, args.table_name, args.new_epoch)
4665 msg_type = TMessageType.REPLY
4666 except TTransport.TTransportException:
4668 except TOmniSciException
as e:
4669 msg_type = TMessageType.REPLY
4671 except TApplicationException
as ex:
4672 logging.exception(
'TApplication exception in handler')
4673 msg_type = TMessageType.EXCEPTION
4676 logging.exception(
'Unexpected exception in handler')
4677 msg_type = TMessageType.EXCEPTION
4678 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4679 oprot.writeMessageBegin(
"set_table_epoch_by_name", msg_type, seqid)
4681 oprot.writeMessageEnd()
4687 iprot.readMessageEnd()
4690 result.success = self._handler.get_table_epoch(args.session, args.db_id, args.table_id)
4691 msg_type = TMessageType.REPLY
4692 except TTransport.TTransportException:
4694 except TApplicationException
as ex:
4695 logging.exception(
'TApplication exception in handler')
4696 msg_type = TMessageType.EXCEPTION
4699 logging.exception(
'Unexpected exception in handler')
4700 msg_type = TMessageType.EXCEPTION
4701 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4702 oprot.writeMessageBegin(
"get_table_epoch", msg_type, seqid)
4704 oprot.writeMessageEnd()
4710 iprot.readMessageEnd()
4713 result.success = self._handler.get_table_epoch_by_name(args.session, args.table_name)
4714 msg_type = TMessageType.REPLY
4715 except TTransport.TTransportException:
4717 except TApplicationException
as ex:
4718 logging.exception(
'TApplication exception in handler')
4719 msg_type = TMessageType.EXCEPTION
4722 logging.exception(
'Unexpected exception in handler')
4723 msg_type = TMessageType.EXCEPTION
4724 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4725 oprot.writeMessageBegin(
"get_table_epoch_by_name", msg_type, seqid)
4727 oprot.writeMessageEnd()
4733 iprot.readMessageEnd()
4736 result.success = self._handler.get_table_epochs(args.session, args.db_id, args.table_id)
4737 msg_type = TMessageType.REPLY
4738 except TTransport.TTransportException:
4740 except TApplicationException
as ex:
4741 logging.exception(
'TApplication exception in handler')
4742 msg_type = TMessageType.EXCEPTION
4745 logging.exception(
'Unexpected exception in handler')
4746 msg_type = TMessageType.EXCEPTION
4747 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4748 oprot.writeMessageBegin(
"get_table_epochs", msg_type, seqid)
4750 oprot.writeMessageEnd()
4756 iprot.readMessageEnd()
4759 self._handler.set_table_epochs(args.session, args.db_id, args.table_epochs)
4760 msg_type = TMessageType.REPLY
4761 except TTransport.TTransportException:
4763 except TApplicationException
as ex:
4764 logging.exception(
'TApplication exception in handler')
4765 msg_type = TMessageType.EXCEPTION
4768 logging.exception(
'Unexpected exception in handler')
4769 msg_type = TMessageType.EXCEPTION
4770 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4771 oprot.writeMessageBegin(
"set_table_epochs", msg_type, seqid)
4773 oprot.writeMessageEnd()
4779 iprot.readMessageEnd()
4782 result.success = self._handler.get_session_info(args.session)
4783 msg_type = TMessageType.REPLY
4784 except TTransport.TTransportException:
4786 except TOmniSciException
as e:
4787 msg_type = TMessageType.REPLY
4789 except TApplicationException
as ex:
4790 logging.exception(
'TApplication exception in handler')
4791 msg_type = TMessageType.EXCEPTION
4794 logging.exception(
'Unexpected exception in handler')
4795 msg_type = TMessageType.EXCEPTION
4796 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4797 oprot.writeMessageBegin(
"get_session_info", msg_type, seqid)
4799 oprot.writeMessageEnd()
4805 iprot.readMessageEnd()
4808 result.success = self._handler.sql_execute(args.session, args.query, args.column_format, args.nonce, args.first_n, args.at_most_n)
4809 msg_type = TMessageType.REPLY
4810 except TTransport.TTransportException:
4812 except TOmniSciException
as e:
4813 msg_type = TMessageType.REPLY
4815 except TApplicationException
as ex:
4816 logging.exception(
'TApplication exception in handler')
4817 msg_type = TMessageType.EXCEPTION
4820 logging.exception(
'Unexpected exception in handler')
4821 msg_type = TMessageType.EXCEPTION
4822 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4823 oprot.writeMessageBegin(
"sql_execute", msg_type, seqid)
4825 oprot.writeMessageEnd()
4831 iprot.readMessageEnd()
4834 result.success = self._handler.sql_execute_df(args.session, args.query, args.device_type, args.device_id, args.first_n, args.transport_method)
4835 msg_type = TMessageType.REPLY
4836 except TTransport.TTransportException:
4838 except TOmniSciException
as e:
4839 msg_type = TMessageType.REPLY
4841 except TApplicationException
as ex:
4842 logging.exception(
'TApplication exception in handler')
4843 msg_type = TMessageType.EXCEPTION
4846 logging.exception(
'Unexpected exception in handler')
4847 msg_type = TMessageType.EXCEPTION
4848 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4849 oprot.writeMessageBegin(
"sql_execute_df", msg_type, seqid)
4851 oprot.writeMessageEnd()
4857 iprot.readMessageEnd()
4860 result.success = self._handler.sql_execute_gdf(args.session, args.query, args.device_id, args.first_n)
4861 msg_type = TMessageType.REPLY
4862 except TTransport.TTransportException:
4864 except TOmniSciException
as e:
4865 msg_type = TMessageType.REPLY
4867 except TApplicationException
as ex:
4868 logging.exception(
'TApplication exception in handler')
4869 msg_type = TMessageType.EXCEPTION
4872 logging.exception(
'Unexpected exception in handler')
4873 msg_type = TMessageType.EXCEPTION
4874 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4875 oprot.writeMessageBegin(
"sql_execute_gdf", msg_type, seqid)
4877 oprot.writeMessageEnd()
4883 iprot.readMessageEnd()
4886 self._handler.deallocate_df(args.session, args.df, args.device_type, args.device_id)
4887 msg_type = TMessageType.REPLY
4888 except TTransport.TTransportException:
4890 except TOmniSciException
as e:
4891 msg_type = TMessageType.REPLY
4893 except TApplicationException
as ex:
4894 logging.exception(
'TApplication exception in handler')
4895 msg_type = TMessageType.EXCEPTION
4898 logging.exception(
'Unexpected exception in handler')
4899 msg_type = TMessageType.EXCEPTION
4900 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4901 oprot.writeMessageBegin(
"deallocate_df", msg_type, seqid)
4903 oprot.writeMessageEnd()
4909 iprot.readMessageEnd()
4912 self._handler.interrupt(args.query_session, args.interrupt_session)
4913 msg_type = TMessageType.REPLY
4914 except TTransport.TTransportException:
4916 except TOmniSciException
as e:
4917 msg_type = TMessageType.REPLY
4919 except TApplicationException
as ex:
4920 logging.exception(
'TApplication exception in handler')
4921 msg_type = TMessageType.EXCEPTION
4924 logging.exception(
'Unexpected exception in handler')
4925 msg_type = TMessageType.EXCEPTION
4926 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4927 oprot.writeMessageBegin(
"interrupt", msg_type, seqid)
4929 oprot.writeMessageEnd()
4935 iprot.readMessageEnd()
4938 result.success = self._handler.sql_validate(args.session, args.query)
4939 msg_type = TMessageType.REPLY
4940 except TTransport.TTransportException:
4942 except TOmniSciException
as e:
4943 msg_type = TMessageType.REPLY
4945 except TApplicationException
as ex:
4946 logging.exception(
'TApplication exception in handler')
4947 msg_type = TMessageType.EXCEPTION
4950 logging.exception(
'Unexpected exception in handler')
4951 msg_type = TMessageType.EXCEPTION
4952 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4953 oprot.writeMessageBegin(
"sql_validate", msg_type, seqid)
4955 oprot.writeMessageEnd()
4961 iprot.readMessageEnd()
4964 result.success = self._handler.get_completion_hints(args.session, args.sql, args.cursor)
4965 msg_type = TMessageType.REPLY
4966 except TTransport.TTransportException:
4968 except TOmniSciException
as e:
4969 msg_type = TMessageType.REPLY
4971 except TApplicationException
as ex:
4972 logging.exception(
'TApplication exception in handler')
4973 msg_type = TMessageType.EXCEPTION
4976 logging.exception(
'Unexpected exception in handler')
4977 msg_type = TMessageType.EXCEPTION
4978 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
4979 oprot.writeMessageBegin(
"get_completion_hints", msg_type, seqid)
4981 oprot.writeMessageEnd()
4987 iprot.readMessageEnd()
4990 self._handler.set_execution_mode(args.session, args.mode)
4991 msg_type = TMessageType.REPLY
4992 except TTransport.TTransportException:
4994 except TOmniSciException
as e:
4995 msg_type = TMessageType.REPLY
4997 except TApplicationException
as ex:
4998 logging.exception(
'TApplication exception in handler')
4999 msg_type = TMessageType.EXCEPTION
5002 logging.exception(
'Unexpected exception in handler')
5003 msg_type = TMessageType.EXCEPTION
5004 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5005 oprot.writeMessageBegin(
"set_execution_mode", msg_type, seqid)
5007 oprot.writeMessageEnd()
5013 iprot.readMessageEnd()
5016 result.success = self._handler.render_vega(args.session, args.widget_id, args.vega_json, args.compression_level, args.nonce)
5017 msg_type = TMessageType.REPLY
5018 except TTransport.TTransportException:
5020 except TOmniSciException
as e:
5021 msg_type = TMessageType.REPLY
5023 except TApplicationException
as ex:
5024 logging.exception(
'TApplication exception in handler')
5025 msg_type = TMessageType.EXCEPTION
5028 logging.exception(
'Unexpected exception in handler')
5029 msg_type = TMessageType.EXCEPTION
5030 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5031 oprot.writeMessageBegin(
"render_vega", msg_type, seqid)
5033 oprot.writeMessageEnd()
5039 iprot.readMessageEnd()
5042 result.success = self._handler.get_result_row_for_pixel(args.session, args.widget_id, args.pixel, args.table_col_names, args.column_format, args.pixelRadius, args.nonce)
5043 msg_type = TMessageType.REPLY
5044 except TTransport.TTransportException:
5046 except TOmniSciException
as e:
5047 msg_type = TMessageType.REPLY
5049 except TApplicationException
as ex:
5050 logging.exception(
'TApplication exception in handler')
5051 msg_type = TMessageType.EXCEPTION
5054 logging.exception(
'Unexpected exception in handler')
5055 msg_type = TMessageType.EXCEPTION
5056 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5057 oprot.writeMessageBegin(
"get_result_row_for_pixel", msg_type, seqid)
5059 oprot.writeMessageEnd()
5065 iprot.readMessageEnd()
5068 result.success = self._handler.get_dashboard(args.session, args.dashboard_id)
5069 msg_type = TMessageType.REPLY
5070 except TTransport.TTransportException:
5072 except TOmniSciException
as e:
5073 msg_type = TMessageType.REPLY
5075 except TApplicationException
as ex:
5076 logging.exception(
'TApplication exception in handler')
5077 msg_type = TMessageType.EXCEPTION
5080 logging.exception(
'Unexpected exception in handler')
5081 msg_type = TMessageType.EXCEPTION
5082 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5083 oprot.writeMessageBegin(
"get_dashboard", msg_type, seqid)
5085 oprot.writeMessageEnd()
5091 iprot.readMessageEnd()
5094 result.success = self._handler.get_dashboards(args.session)
5095 msg_type = TMessageType.REPLY
5096 except TTransport.TTransportException:
5098 except TOmniSciException
as e:
5099 msg_type = TMessageType.REPLY
5101 except TApplicationException
as ex:
5102 logging.exception(
'TApplication exception in handler')
5103 msg_type = TMessageType.EXCEPTION
5106 logging.exception(
'Unexpected exception in handler')
5107 msg_type = TMessageType.EXCEPTION
5108 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5109 oprot.writeMessageBegin(
"get_dashboards", msg_type, seqid)
5111 oprot.writeMessageEnd()
5117 iprot.readMessageEnd()
5120 result.success = self._handler.create_dashboard(args.session, args.dashboard_name, args.dashboard_state, args.image_hash, args.dashboard_metadata)
5121 msg_type = TMessageType.REPLY
5122 except TTransport.TTransportException:
5124 except TOmniSciException
as e:
5125 msg_type = TMessageType.REPLY
5127 except TApplicationException
as ex:
5128 logging.exception(
'TApplication exception in handler')
5129 msg_type = TMessageType.EXCEPTION
5132 logging.exception(
'Unexpected exception in handler')
5133 msg_type = TMessageType.EXCEPTION
5134 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5135 oprot.writeMessageBegin(
"create_dashboard", msg_type, seqid)
5137 oprot.writeMessageEnd()
5143 iprot.readMessageEnd()
5146 self._handler.replace_dashboard(args.session, args.dashboard_id, args.dashboard_name, args.dashboard_owner, args.dashboard_state, args.image_hash, args.dashboard_metadata)
5147 msg_type = TMessageType.REPLY
5148 except TTransport.TTransportException:
5150 except TOmniSciException
as e:
5151 msg_type = TMessageType.REPLY
5153 except TApplicationException
as ex:
5154 logging.exception(
'TApplication exception in handler')
5155 msg_type = TMessageType.EXCEPTION
5158 logging.exception(
'Unexpected exception in handler')
5159 msg_type = TMessageType.EXCEPTION
5160 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5161 oprot.writeMessageBegin(
"replace_dashboard", msg_type, seqid)
5163 oprot.writeMessageEnd()
5169 iprot.readMessageEnd()
5172 self._handler.delete_dashboard(args.session, args.dashboard_id)
5173 msg_type = TMessageType.REPLY
5174 except TTransport.TTransportException:
5176 except TOmniSciException
as e:
5177 msg_type = TMessageType.REPLY
5179 except TApplicationException
as ex:
5180 logging.exception(
'TApplication exception in handler')
5181 msg_type = TMessageType.EXCEPTION
5184 logging.exception(
'Unexpected exception in handler')
5185 msg_type = TMessageType.EXCEPTION
5186 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5187 oprot.writeMessageBegin(
"delete_dashboard", msg_type, seqid)
5189 oprot.writeMessageEnd()
5195 iprot.readMessageEnd()
5198 self._handler.share_dashboards(args.session, args.dashboard_ids, args.groups, args.permissions)
5199 msg_type = TMessageType.REPLY
5200 except TTransport.TTransportException:
5202 except TOmniSciException
as e:
5203 msg_type = TMessageType.REPLY
5205 except TApplicationException
as ex:
5206 logging.exception(
'TApplication exception in handler')
5207 msg_type = TMessageType.EXCEPTION
5210 logging.exception(
'Unexpected exception in handler')
5211 msg_type = TMessageType.EXCEPTION
5212 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5213 oprot.writeMessageBegin(
"share_dashboards", msg_type, seqid)
5215 oprot.writeMessageEnd()
5221 iprot.readMessageEnd()
5224 self._handler.delete_dashboards(args.session, args.dashboard_ids)
5225 msg_type = TMessageType.REPLY
5226 except TTransport.TTransportException:
5228 except TOmniSciException
as e:
5229 msg_type = TMessageType.REPLY
5231 except TApplicationException
as ex:
5232 logging.exception(
'TApplication exception in handler')
5233 msg_type = TMessageType.EXCEPTION
5236 logging.exception(
'Unexpected exception in handler')
5237 msg_type = TMessageType.EXCEPTION
5238 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5239 oprot.writeMessageBegin(
"delete_dashboards", msg_type, seqid)
5241 oprot.writeMessageEnd()
5247 iprot.readMessageEnd()
5250 self._handler.share_dashboard(args.session, args.dashboard_id, args.groups, args.objects, args.permissions, args.grant_role)
5251 msg_type = TMessageType.REPLY
5252 except TTransport.TTransportException:
5254 except TOmniSciException
as e:
5255 msg_type = TMessageType.REPLY
5257 except TApplicationException
as ex:
5258 logging.exception(
'TApplication exception in handler')
5259 msg_type = TMessageType.EXCEPTION
5262 logging.exception(
'Unexpected exception in handler')
5263 msg_type = TMessageType.EXCEPTION
5264 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5265 oprot.writeMessageBegin(
"share_dashboard", msg_type, seqid)
5267 oprot.writeMessageEnd()
5273 iprot.readMessageEnd()
5276 self._handler.unshare_dashboard(args.session, args.dashboard_id, args.groups, args.objects, args.permissions)
5277 msg_type = TMessageType.REPLY
5278 except TTransport.TTransportException:
5280 except TOmniSciException
as e:
5281 msg_type = TMessageType.REPLY
5283 except TApplicationException
as ex:
5284 logging.exception(
'TApplication exception in handler')
5285 msg_type = TMessageType.EXCEPTION
5288 logging.exception(
'Unexpected exception in handler')
5289 msg_type = TMessageType.EXCEPTION
5290 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5291 oprot.writeMessageBegin(
"unshare_dashboard", msg_type, seqid)
5293 oprot.writeMessageEnd()
5299 iprot.readMessageEnd()
5302 self._handler.unshare_dashboards(args.session, args.dashboard_ids, args.groups, args.permissions)
5303 msg_type = TMessageType.REPLY
5304 except TTransport.TTransportException:
5306 except TOmniSciException
as e:
5307 msg_type = TMessageType.REPLY
5309 except TApplicationException
as ex:
5310 logging.exception(
'TApplication exception in handler')
5311 msg_type = TMessageType.EXCEPTION
5314 logging.exception(
'Unexpected exception in handler')
5315 msg_type = TMessageType.EXCEPTION
5316 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5317 oprot.writeMessageBegin(
"unshare_dashboards", msg_type, seqid)
5319 oprot.writeMessageEnd()
5325 iprot.readMessageEnd()
5328 result.success = self._handler.get_dashboard_grantees(args.session, args.dashboard_id)
5329 msg_type = TMessageType.REPLY
5330 except TTransport.TTransportException:
5332 except TOmniSciException
as e:
5333 msg_type = TMessageType.REPLY
5335 except TApplicationException
as ex:
5336 logging.exception(
'TApplication exception in handler')
5337 msg_type = TMessageType.EXCEPTION
5340 logging.exception(
'Unexpected exception in handler')
5341 msg_type = TMessageType.EXCEPTION
5342 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5343 oprot.writeMessageBegin(
"get_dashboard_grantees", msg_type, seqid)
5345 oprot.writeMessageEnd()
5351 iprot.readMessageEnd()
5354 result.success = self._handler.get_link_view(args.session, args.link)
5355 msg_type = TMessageType.REPLY
5356 except TTransport.TTransportException:
5358 except TOmniSciException
as e:
5359 msg_type = TMessageType.REPLY
5361 except TApplicationException
as ex:
5362 logging.exception(
'TApplication exception in handler')
5363 msg_type = TMessageType.EXCEPTION
5366 logging.exception(
'Unexpected exception in handler')
5367 msg_type = TMessageType.EXCEPTION
5368 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5369 oprot.writeMessageBegin(
"get_link_view", msg_type, seqid)
5371 oprot.writeMessageEnd()
5377 iprot.readMessageEnd()
5380 result.success = self._handler.create_link(args.session, args.view_state, args.view_metadata)
5381 msg_type = TMessageType.REPLY
5382 except TTransport.TTransportException:
5384 except TOmniSciException
as e:
5385 msg_type = TMessageType.REPLY
5387 except TApplicationException
as ex:
5388 logging.exception(
'TApplication exception in handler')
5389 msg_type = TMessageType.EXCEPTION
5392 logging.exception(
'Unexpected exception in handler')
5393 msg_type = TMessageType.EXCEPTION
5394 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5395 oprot.writeMessageBegin(
"create_link", msg_type, seqid)
5397 oprot.writeMessageEnd()
5403 iprot.readMessageEnd()
5406 self._handler.load_table_binary(args.session, args.table_name, args.rows, args.column_names)
5407 msg_type = TMessageType.REPLY
5408 except TTransport.TTransportException:
5410 except TOmniSciException
as e:
5411 msg_type = TMessageType.REPLY
5413 except TApplicationException
as ex:
5414 logging.exception(
'TApplication exception in handler')
5415 msg_type = TMessageType.EXCEPTION
5418 logging.exception(
'Unexpected exception in handler')
5419 msg_type = TMessageType.EXCEPTION
5420 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5421 oprot.writeMessageBegin(
"load_table_binary", msg_type, seqid)
5423 oprot.writeMessageEnd()
5429 iprot.readMessageEnd()
5432 self._handler.load_table_binary_columnar(args.session, args.table_name, args.cols, args.column_names)
5433 msg_type = TMessageType.REPLY
5434 except TTransport.TTransportException:
5436 except TOmniSciException
as e:
5437 msg_type = TMessageType.REPLY
5439 except TApplicationException
as ex:
5440 logging.exception(
'TApplication exception in handler')
5441 msg_type = TMessageType.EXCEPTION
5444 logging.exception(
'Unexpected exception in handler')
5445 msg_type = TMessageType.EXCEPTION
5446 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5447 oprot.writeMessageBegin(
"load_table_binary_columnar", msg_type, seqid)
5449 oprot.writeMessageEnd()
5455 iprot.readMessageEnd()
5458 self._handler.load_table_binary_arrow(args.session, args.table_name, args.arrow_stream, args.use_column_names)
5459 msg_type = TMessageType.REPLY
5460 except TTransport.TTransportException:
5462 except TOmniSciException
as e:
5463 msg_type = TMessageType.REPLY
5465 except TApplicationException
as ex:
5466 logging.exception(
'TApplication exception in handler')
5467 msg_type = TMessageType.EXCEPTION
5470 logging.exception(
'Unexpected exception in handler')
5471 msg_type = TMessageType.EXCEPTION
5472 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5473 oprot.writeMessageBegin(
"load_table_binary_arrow", msg_type, seqid)
5475 oprot.writeMessageEnd()
5481 iprot.readMessageEnd()
5484 self._handler.load_table(args.session, args.table_name, args.rows, args.column_names)
5485 msg_type = TMessageType.REPLY
5486 except TTransport.TTransportException:
5488 except TOmniSciException
as e:
5489 msg_type = TMessageType.REPLY
5491 except TApplicationException
as ex:
5492 logging.exception(
'TApplication exception in handler')
5493 msg_type = TMessageType.EXCEPTION
5496 logging.exception(
'Unexpected exception in handler')
5497 msg_type = TMessageType.EXCEPTION
5498 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5499 oprot.writeMessageBegin(
"load_table", msg_type, seqid)
5501 oprot.writeMessageEnd()
5507 iprot.readMessageEnd()
5510 result.success = self._handler.detect_column_types(args.session, args.file_name, args.copy_params)
5511 msg_type = TMessageType.REPLY
5512 except TTransport.TTransportException:
5514 except TOmniSciException
as e:
5515 msg_type = TMessageType.REPLY
5517 except TApplicationException
as ex:
5518 logging.exception(
'TApplication exception in handler')
5519 msg_type = TMessageType.EXCEPTION
5522 logging.exception(
'Unexpected exception in handler')
5523 msg_type = TMessageType.EXCEPTION
5524 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5525 oprot.writeMessageBegin(
"detect_column_types", msg_type, seqid)
5527 oprot.writeMessageEnd()
5533 iprot.readMessageEnd()
5536 self._handler.create_table(args.session, args.table_name, args.row_desc, args.file_type, args.create_params)
5537 msg_type = TMessageType.REPLY
5538 except TTransport.TTransportException:
5540 except TOmniSciException
as e:
5541 msg_type = TMessageType.REPLY
5543 except TApplicationException
as ex:
5544 logging.exception(
'TApplication exception in handler')
5545 msg_type = TMessageType.EXCEPTION
5548 logging.exception(
'Unexpected exception in handler')
5549 msg_type = TMessageType.EXCEPTION
5550 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5551 oprot.writeMessageBegin(
"create_table", msg_type, seqid)
5553 oprot.writeMessageEnd()
5559 iprot.readMessageEnd()
5562 self._handler.import_table(args.session, args.table_name, args.file_name, args.copy_params)
5563 msg_type = TMessageType.REPLY
5564 except TTransport.TTransportException:
5566 except TOmniSciException
as e:
5567 msg_type = TMessageType.REPLY
5569 except TApplicationException
as ex:
5570 logging.exception(
'TApplication exception in handler')
5571 msg_type = TMessageType.EXCEPTION
5574 logging.exception(
'Unexpected exception in handler')
5575 msg_type = TMessageType.EXCEPTION
5576 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5577 oprot.writeMessageBegin(
"import_table", msg_type, seqid)
5579 oprot.writeMessageEnd()
5585 iprot.readMessageEnd()
5588 self._handler.import_geo_table(args.session, args.table_name, args.file_name, args.copy_params, args.row_desc, args.create_params)
5589 msg_type = TMessageType.REPLY
5590 except TTransport.TTransportException:
5592 except TOmniSciException
as e:
5593 msg_type = TMessageType.REPLY
5595 except TApplicationException
as ex:
5596 logging.exception(
'TApplication exception in handler')
5597 msg_type = TMessageType.EXCEPTION
5600 logging.exception(
'Unexpected exception in handler')
5601 msg_type = TMessageType.EXCEPTION
5602 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5603 oprot.writeMessageBegin(
"import_geo_table", msg_type, seqid)
5605 oprot.writeMessageEnd()
5611 iprot.readMessageEnd()
5614 result.success = self._handler.import_table_status(args.session, args.import_id)
5615 msg_type = TMessageType.REPLY
5616 except TTransport.TTransportException:
5618 except TOmniSciException
as e:
5619 msg_type = TMessageType.REPLY
5621 except TApplicationException
as ex:
5622 logging.exception(
'TApplication exception in handler')
5623 msg_type = TMessageType.EXCEPTION
5626 logging.exception(
'Unexpected exception in handler')
5627 msg_type = TMessageType.EXCEPTION
5628 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5629 oprot.writeMessageBegin(
"import_table_status", msg_type, seqid)
5631 oprot.writeMessageEnd()
5637 iprot.readMessageEnd()
5640 result.success = self._handler.get_first_geo_file_in_archive(args.session, args.archive_path, args.copy_params)
5641 msg_type = TMessageType.REPLY
5642 except TTransport.TTransportException:
5644 except TOmniSciException
as e:
5645 msg_type = TMessageType.REPLY
5647 except TApplicationException
as ex:
5648 logging.exception(
'TApplication exception in handler')
5649 msg_type = TMessageType.EXCEPTION
5652 logging.exception(
'Unexpected exception in handler')
5653 msg_type = TMessageType.EXCEPTION
5654 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5655 oprot.writeMessageBegin(
"get_first_geo_file_in_archive", msg_type, seqid)
5657 oprot.writeMessageEnd()
5663 iprot.readMessageEnd()
5666 result.success = self._handler.get_all_files_in_archive(args.session, args.archive_path, args.copy_params)
5667 msg_type = TMessageType.REPLY
5668 except TTransport.TTransportException:
5670 except TOmniSciException
as e:
5671 msg_type = TMessageType.REPLY
5673 except TApplicationException
as ex:
5674 logging.exception(
'TApplication exception in handler')
5675 msg_type = TMessageType.EXCEPTION
5678 logging.exception(
'Unexpected exception in handler')
5679 msg_type = TMessageType.EXCEPTION
5680 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5681 oprot.writeMessageBegin(
"get_all_files_in_archive", msg_type, seqid)
5683 oprot.writeMessageEnd()
5689 iprot.readMessageEnd()
5692 result.success = self._handler.get_layers_in_geo_file(args.session, args.file_name, args.copy_params)
5693 msg_type = TMessageType.REPLY
5694 except TTransport.TTransportException:
5696 except TOmniSciException
as e:
5697 msg_type = TMessageType.REPLY
5699 except TApplicationException
as ex:
5700 logging.exception(
'TApplication exception in handler')
5701 msg_type = TMessageType.EXCEPTION
5704 logging.exception(
'Unexpected exception in handler')
5705 msg_type = TMessageType.EXCEPTION
5706 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5707 oprot.writeMessageBegin(
"get_layers_in_geo_file", msg_type, seqid)
5709 oprot.writeMessageEnd()
5715 iprot.readMessageEnd()
5718 result.success = self._handler.query_get_outer_fragment_count(args.session, args.query)
5719 msg_type = TMessageType.REPLY
5720 except TTransport.TTransportException:
5722 except TOmniSciException
as e:
5723 msg_type = TMessageType.REPLY
5725 except TApplicationException
as ex:
5726 logging.exception(
'TApplication exception in handler')
5727 msg_type = TMessageType.EXCEPTION
5730 logging.exception(
'Unexpected exception in handler')
5731 msg_type = TMessageType.EXCEPTION
5732 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5733 oprot.writeMessageBegin(
"query_get_outer_fragment_count", msg_type, seqid)
5735 oprot.writeMessageEnd()
5741 iprot.readMessageEnd()
5744 result.success = self._handler.check_table_consistency(args.session, args.table_id)
5745 msg_type = TMessageType.REPLY
5746 except TTransport.TTransportException:
5748 except TOmniSciException
as e:
5749 msg_type = TMessageType.REPLY
5751 except TApplicationException
as ex:
5752 logging.exception(
'TApplication exception in handler')
5753 msg_type = TMessageType.EXCEPTION
5756 logging.exception(
'Unexpected exception in handler')
5757 msg_type = TMessageType.EXCEPTION
5758 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5759 oprot.writeMessageBegin(
"check_table_consistency", msg_type, seqid)
5761 oprot.writeMessageEnd()
5767 iprot.readMessageEnd()
5770 result.success = self._handler.start_query(args.leaf_session, args.parent_session, args.query_ra, args.just_explain, args.outer_fragment_indices)
5771 msg_type = TMessageType.REPLY
5772 except TTransport.TTransportException:
5774 except TOmniSciException
as e:
5775 msg_type = TMessageType.REPLY
5777 except TApplicationException
as ex:
5778 logging.exception(
'TApplication exception in handler')
5779 msg_type = TMessageType.EXCEPTION
5782 logging.exception(
'Unexpected exception in handler')
5783 msg_type = TMessageType.EXCEPTION
5784 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5785 oprot.writeMessageBegin(
"start_query", msg_type, seqid)
5787 oprot.writeMessageEnd()
5793 iprot.readMessageEnd()
5796 result.success = self._handler.execute_query_step(args.pending_query, args.subquery_id)
5797 msg_type = TMessageType.REPLY
5798 except TTransport.TTransportException:
5800 except TOmniSciException
as e:
5801 msg_type = TMessageType.REPLY
5803 except TApplicationException
as ex:
5804 logging.exception(
'TApplication exception in handler')
5805 msg_type = TMessageType.EXCEPTION
5808 logging.exception(
'Unexpected exception in handler')
5809 msg_type = TMessageType.EXCEPTION
5810 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5811 oprot.writeMessageBegin(
"execute_query_step", msg_type, seqid)
5813 oprot.writeMessageEnd()
5819 iprot.readMessageEnd()
5822 self._handler.broadcast_serialized_rows(args.serialized_rows, args.row_desc, args.query_id, args.subquery_id, args.is_final_subquery_result)
5823 msg_type = TMessageType.REPLY
5824 except TTransport.TTransportException:
5826 except TOmniSciException
as e:
5827 msg_type = TMessageType.REPLY
5829 except TApplicationException
as ex:
5830 logging.exception(
'TApplication exception in handler')
5831 msg_type = TMessageType.EXCEPTION
5834 logging.exception(
'Unexpected exception in handler')
5835 msg_type = TMessageType.EXCEPTION
5836 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5837 oprot.writeMessageBegin(
"broadcast_serialized_rows", msg_type, seqid)
5839 oprot.writeMessageEnd()
5845 iprot.readMessageEnd()
5848 result.success = self._handler.start_render_query(args.session, args.widget_id, args.node_idx, args.vega_json)
5849 msg_type = TMessageType.REPLY
5850 except TTransport.TTransportException:
5852 except TOmniSciException
as e:
5853 msg_type = TMessageType.REPLY
5855 except TApplicationException
as ex:
5856 logging.exception(
'TApplication exception in handler')
5857 msg_type = TMessageType.EXCEPTION
5860 logging.exception(
'Unexpected exception in handler')
5861 msg_type = TMessageType.EXCEPTION
5862 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5863 oprot.writeMessageBegin(
"start_render_query", msg_type, seqid)
5865 oprot.writeMessageEnd()
5871 iprot.readMessageEnd()
5874 result.success = self._handler.execute_next_render_step(args.pending_render, args.merged_data)
5875 msg_type = TMessageType.REPLY
5876 except TTransport.TTransportException:
5878 except TOmniSciException
as e:
5879 msg_type = TMessageType.REPLY
5881 except TApplicationException
as ex:
5882 logging.exception(
'TApplication exception in handler')
5883 msg_type = TMessageType.EXCEPTION
5886 logging.exception(
'Unexpected exception in handler')
5887 msg_type = TMessageType.EXCEPTION
5888 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5889 oprot.writeMessageBegin(
"execute_next_render_step", msg_type, seqid)
5891 oprot.writeMessageEnd()
5897 iprot.readMessageEnd()
5900 self._handler.insert_data(args.session, args.insert_data)
5901 msg_type = TMessageType.REPLY
5902 except TTransport.TTransportException:
5904 except TOmniSciException
as e:
5905 msg_type = TMessageType.REPLY
5907 except TApplicationException
as ex:
5908 logging.exception(
'TApplication exception in handler')
5909 msg_type = TMessageType.EXCEPTION
5912 logging.exception(
'Unexpected exception in handler')
5913 msg_type = TMessageType.EXCEPTION
5914 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5915 oprot.writeMessageBegin(
"insert_data", msg_type, seqid)
5917 oprot.writeMessageEnd()
5923 iprot.readMessageEnd()
5926 self._handler.checkpoint(args.session, args.table_id)
5927 msg_type = TMessageType.REPLY
5928 except TTransport.TTransportException:
5930 except TOmniSciException
as e:
5931 msg_type = TMessageType.REPLY
5933 except TApplicationException
as ex:
5934 logging.exception(
'TApplication exception in handler')
5935 msg_type = TMessageType.EXCEPTION
5938 logging.exception(
'Unexpected exception in handler')
5939 msg_type = TMessageType.EXCEPTION
5940 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5941 oprot.writeMessageBegin(
"checkpoint", msg_type, seqid)
5943 oprot.writeMessageEnd()
5949 iprot.readMessageEnd()
5952 result.success = self._handler.get_roles(args.session)
5953 msg_type = TMessageType.REPLY
5954 except TTransport.TTransportException:
5956 except TOmniSciException
as e:
5957 msg_type = TMessageType.REPLY
5959 except TApplicationException
as ex:
5960 logging.exception(
'TApplication exception in handler')
5961 msg_type = TMessageType.EXCEPTION
5964 logging.exception(
'Unexpected exception in handler')
5965 msg_type = TMessageType.EXCEPTION
5966 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5967 oprot.writeMessageBegin(
"get_roles", msg_type, seqid)
5969 oprot.writeMessageEnd()
5975 iprot.readMessageEnd()
5978 result.success = self._handler.get_db_objects_for_grantee(args.session, args.roleName)
5979 msg_type = TMessageType.REPLY
5980 except TTransport.TTransportException:
5982 except TOmniSciException
as e:
5983 msg_type = TMessageType.REPLY
5985 except TApplicationException
as ex:
5986 logging.exception(
'TApplication exception in handler')
5987 msg_type = TMessageType.EXCEPTION
5990 logging.exception(
'Unexpected exception in handler')
5991 msg_type = TMessageType.EXCEPTION
5992 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
5993 oprot.writeMessageBegin(
"get_db_objects_for_grantee", msg_type, seqid)
5995 oprot.writeMessageEnd()
6001 iprot.readMessageEnd()
6004 result.success = self._handler.get_db_object_privs(args.session, args.objectName, args.type)
6005 msg_type = TMessageType.REPLY
6006 except TTransport.TTransportException:
6008 except TOmniSciException
as e:
6009 msg_type = TMessageType.REPLY
6011 except TApplicationException
as ex:
6012 logging.exception(
'TApplication exception in handler')
6013 msg_type = TMessageType.EXCEPTION
6016 logging.exception(
'Unexpected exception in handler')
6017 msg_type = TMessageType.EXCEPTION
6018 result = TApplicationException(TApplicationException.INTERNAL_ERROR,
'Internal error')
6019 oprot.writeMessageBegin(
"get_db_object_privs", msg_type, seqid)
6021 oprot.writeMessageEnd()
6027 iprot.readMessageEnd()
6030 result.success = self._handler.get_all_roles_for_user(args.session, args.userName)
6031 msg_type = TMessageType.REPLY
6032 except TTransport.TTransportException:
6034 except TOmniSciException
as e:
6035 msg_type = TMessageType.REPLY
6037 except TApplicationException
as ex:
6038 logging.exception(
'TApplication exception in handler')
6039 msg_type = TMessageType.EXCEPTION
6042 logging.exception(
'Unexpected exception in handler')