http://git-wip-us.apache.org/repos/asf/hive/blob/26535378/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py index 8354d38..59c7b94 100644 --- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py +++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py @@ -1,5 +1,5 @@ # -# Autogenerated by Thrift Compiler (0.9.2) +# Autogenerated by Thrift Compiler (0.9.3) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # @@ -8,6 +8,7 @@ from thrift.Thrift import TType, TMessageType, TException, TApplicationException import fb303.FacebookService +import logging from ttypes import * from thrift.Thrift import TProcessor from thrift.transport import TTransport @@ -1091,7 +1092,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "getMetaConf failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getMetaConf failed: unknown result") def setMetaConf(self, key, value): """ @@ -1194,7 +1195,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_database failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_database failed: unknown result") def drop_database(self, name, deleteData, cascade): """ @@ -1266,7 +1267,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_databases failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_databases failed: unknown result") def get_all_databases(self): self.send_get_all_databases() @@ -1294,7 +1295,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_all_databases failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_all_databases failed: unknown result") def alter_database(self, dbname, db): """ @@ -1364,7 +1365,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_type failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_type failed: unknown result") def create_type(self, type): """ @@ -1401,7 +1402,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 if result.o3 is not None: raise result.o3 - raise TApplicationException(TApplicationException.MISSING_RESULT, "create_type failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "create_type failed: unknown result") def drop_type(self, type): """ @@ -1436,7 +1437,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_type failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_type failed: unknown result") def get_type_all(self, name): """ @@ -1469,7 +1470,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_type_all failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_type_all failed: unknown result") def get_fields(self, db_name, table_name): """ @@ -1508,7 +1509,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 if result.o3 is not None: raise result.o3 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_fields failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_fields failed: unknown result") def get_fields_with_environment_context(self, db_name, table_name, environment_context): """ @@ -1549,7 +1550,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 if result.o3 is not None: raise result.o3 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_fields_with_environment_context failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_fields_with_environment_context failed: unknown result") def get_schema(self, db_name, table_name): """ @@ -1588,7 +1589,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 if result.o3 is not None: raise result.o3 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_schema failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_schema failed: unknown result") def get_schema_with_environment_context(self, db_name, table_name, environment_context): """ @@ -1629,7 +1630,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 if result.o3 is not None: raise result.o3 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_schema_with_environment_context failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_schema_with_environment_context failed: unknown result") def create_table(self, tbl): """ @@ -1816,7 +1817,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_tables failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_tables failed: unknown result") def get_all_tables(self, db_name): """ @@ -1849,7 +1850,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_all_tables failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_all_tables failed: unknown result") def get_table(self, dbname, tbl_name): """ @@ -1886,7 +1887,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table failed: unknown result") def get_table_objects_by_name(self, dbname, tbl_names): """ @@ -1925,7 +1926,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 if result.o3 is not None: raise result.o3 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_objects_by_name failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_objects_by_name failed: unknown result") def get_table_names_by_filter(self, dbname, filter, max_tables): """ @@ -1966,7 +1967,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 if result.o3 is not None: raise result.o3 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_names_by_filter failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_names_by_filter failed: unknown result") def alter_table(self, dbname, tbl_name, new_tbl): """ @@ -2118,7 +2119,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 if result.o3 is not None: raise result.o3 - raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partition failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partition failed: unknown result") def add_partition_with_environment_context(self, new_part, environment_context): """ @@ -2157,7 +2158,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 if result.o3 is not None: raise result.o3 - raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partition_with_environment_context failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partition_with_environment_context failed: unknown result") def add_partitions(self, new_parts): """ @@ -2194,7 +2195,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 if result.o3 is not None: raise result.o3 - raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partitions failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partitions failed: unknown result") def add_partitions_pspec(self, new_parts): """ @@ -2231,7 +2232,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 if result.o3 is not None: raise result.o3 - raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partitions_pspec failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partitions_pspec failed: unknown result") def append_partition(self, db_name, tbl_name, part_vals): """ @@ -2272,7 +2273,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 if result.o3 is not None: raise result.o3 - raise TApplicationException(TApplicationException.MISSING_RESULT, "append_partition failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "append_partition failed: unknown result") def add_partitions_req(self, request): """ @@ -2309,7 +2310,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 if result.o3 is not None: raise result.o3 - raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partitions_req failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partitions_req failed: unknown result") def append_partition_with_environment_context(self, db_name, tbl_name, part_vals, environment_context): """ @@ -2352,7 +2353,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 if result.o3 is not None: raise result.o3 - raise TApplicationException(TApplicationException.MISSING_RESULT, "append_partition_with_environment_context failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "append_partition_with_environment_context failed: unknown result") def append_partition_by_name(self, db_name, tbl_name, part_name): """ @@ -2393,7 +2394,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 if result.o3 is not None: raise result.o3 - raise TApplicationException(TApplicationException.MISSING_RESULT, "append_partition_by_name failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "append_partition_by_name failed: unknown result") def append_partition_by_name_with_environment_context(self, db_name, tbl_name, part_name, environment_context): """ @@ -2436,7 +2437,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 if result.o3 is not None: raise result.o3 - raise TApplicationException(TApplicationException.MISSING_RESULT, "append_partition_by_name_with_environment_context failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "append_partition_by_name_with_environment_context failed: unknown result") def drop_partition(self, db_name, tbl_name, part_vals, deleteData): """ @@ -2477,7 +2478,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition failed: unknown result") def drop_partition_with_environment_context(self, db_name, tbl_name, part_vals, deleteData, environment_context): """ @@ -2520,7 +2521,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition_with_environment_context failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition_with_environment_context failed: unknown result") def drop_partition_by_name(self, db_name, tbl_name, part_name, deleteData): """ @@ -2561,7 +2562,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition_by_name failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition_by_name failed: unknown result") def drop_partition_by_name_with_environment_context(self, db_name, tbl_name, part_name, deleteData, environment_context): """ @@ -2604,7 +2605,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition_by_name_with_environment_context failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition_by_name_with_environment_context failed: unknown result") def drop_partitions_req(self, req): """ @@ -2639,7 +2640,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partitions_req failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partitions_req failed: unknown result") def get_partition(self, db_name, tbl_name, part_vals): """ @@ -2678,7 +2679,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition failed: unknown result") def exchange_partition(self, partitionSpecs, source_db, source_table_name, dest_db, dest_table_name): """ @@ -2725,7 +2726,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o3 if result.o4 is not None: raise result.o4 - raise TApplicationException(TApplicationException.MISSING_RESULT, "exchange_partition failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "exchange_partition failed: unknown result") def get_partition_with_auth(self, db_name, tbl_name, part_vals, user_name, group_names): """ @@ -2768,7 +2769,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_with_auth failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_with_auth failed: unknown result") def get_partition_by_name(self, db_name, tbl_name, part_name): """ @@ -2807,7 +2808,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_by_name failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_by_name failed: unknown result") def get_partitions(self, db_name, tbl_name, max_parts): """ @@ -2846,7 +2847,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions failed: unknown result") def get_partitions_with_auth(self, db_name, tbl_name, max_parts, user_name, group_names): """ @@ -2889,7 +2890,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_with_auth failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_with_auth failed: unknown result") def get_partitions_pspec(self, db_name, tbl_name, max_parts): """ @@ -2928,7 +2929,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_pspec failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_pspec failed: unknown result") def get_partition_names(self, db_name, tbl_name, max_parts): """ @@ -2965,7 +2966,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_names failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_names failed: unknown result") def get_partitions_ps(self, db_name, tbl_name, part_vals, max_parts): """ @@ -3006,7 +3007,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_ps failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_ps failed: unknown result") def get_partitions_ps_with_auth(self, db_name, tbl_name, part_vals, max_parts, user_name, group_names): """ @@ -3051,7 +3052,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_ps_with_auth failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_ps_with_auth failed: unknown result") def get_partition_names_ps(self, db_name, tbl_name, part_vals, max_parts): """ @@ -3092,7 +3093,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_names_ps failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_names_ps failed: unknown result") def get_partitions_by_filter(self, db_name, tbl_name, filter, max_parts): """ @@ -3133,7 +3134,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_by_filter failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_by_filter failed: unknown result") def get_part_specs_by_filter(self, db_name, tbl_name, filter, max_parts): """ @@ -3174,7 +3175,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_part_specs_by_filter failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_part_specs_by_filter failed: unknown result") def get_partitions_by_expr(self, req): """ @@ -3209,7 +3210,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_by_expr failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_by_expr failed: unknown result") def get_partitions_by_names(self, db_name, tbl_name, names): """ @@ -3248,7 +3249,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_by_names failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_by_names failed: unknown result") def alter_partition(self, db_name, tbl_name, new_part): """ @@ -3435,7 +3436,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "partition_name_has_valid_characters failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "partition_name_has_valid_characters failed: unknown result") def get_config_value(self, name, defaultValue): """ @@ -3470,7 +3471,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_config_value failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_config_value failed: unknown result") def partition_name_to_vals(self, part_name): """ @@ -3503,7 +3504,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "partition_name_to_vals failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "partition_name_to_vals failed: unknown result") def partition_name_to_spec(self, part_name): """ @@ -3536,7 +3537,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "partition_name_to_spec failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "partition_name_to_spec failed: unknown result") def markPartitionForEvent(self, db_name, tbl_name, part_vals, eventType): """ @@ -3632,7 +3633,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o5 if result.o6 is not None: raise result.o6 - raise TApplicationException(TApplicationException.MISSING_RESULT, "isPartitionMarkedForEvent failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "isPartitionMarkedForEvent failed: unknown result") def add_index(self, new_index, index_table): """ @@ -3671,7 +3672,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 if result.o3 is not None: raise result.o3 - raise TApplicationException(TApplicationException.MISSING_RESULT, "add_index failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "add_index failed: unknown result") def alter_index(self, dbname, base_tbl_name, idx_name, new_idx): """ @@ -3751,7 +3752,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_index_by_name failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_index_by_name failed: unknown result") def get_index_by_name(self, db_name, tbl_name, index_name): """ @@ -3790,7 +3791,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_index_by_name failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_index_by_name failed: unknown result") def get_indexes(self, db_name, tbl_name, max_indexes): """ @@ -3829,7 +3830,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_indexes failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_indexes failed: unknown result") def get_index_names(self, db_name, tbl_name, max_indexes): """ @@ -3866,7 +3867,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_index_names failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_index_names failed: unknown result") def update_table_column_statistics(self, stats_obj): """ @@ -3905,7 +3906,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o3 if result.o4 is not None: raise result.o4 - raise TApplicationException(TApplicationException.MISSING_RESULT, "update_table_column_statistics failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "update_table_column_statistics failed: unknown result") def update_partition_column_statistics(self, stats_obj): """ @@ -3944,7 +3945,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o3 if result.o4 is not None: raise result.o4 - raise TApplicationException(TApplicationException.MISSING_RESULT, "update_partition_column_statistics failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "update_partition_column_statistics failed: unknown result") def get_table_column_statistics(self, db_name, tbl_name, col_name): """ @@ -3987,7 +3988,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o3 if result.o4 is not None: raise result.o4 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_column_statistics failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_column_statistics failed: unknown result") def get_partition_column_statistics(self, db_name, tbl_name, part_name, col_name): """ @@ -4032,7 +4033,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o3 if result.o4 is not None: raise result.o4 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_column_statistics failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_column_statistics failed: unknown result") def get_table_statistics_req(self, request): """ @@ -4067,7 +4068,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_statistics_req failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_statistics_req failed: unknown result") def get_partitions_statistics_req(self, request): """ @@ -4102,7 +4103,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_statistics_req failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_statistics_req failed: unknown result") def get_aggr_stats_for(self, request): """ @@ -4137,7 +4138,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_aggr_stats_for failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_aggr_stats_for failed: unknown result") def set_aggr_stats_for(self, request): """ @@ -4176,7 +4177,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o3 if result.o4 is not None: raise result.o4 - raise TApplicationException(TApplicationException.MISSING_RESULT, "set_aggr_stats_for failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "set_aggr_stats_for failed: unknown result") def delete_partition_column_statistics(self, db_name, tbl_name, part_name, col_name): """ @@ -4221,7 +4222,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o3 if result.o4 is not None: raise result.o4 - raise TApplicationException(TApplicationException.MISSING_RESULT, "delete_partition_column_statistics failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "delete_partition_column_statistics failed: unknown result") def delete_table_column_statistics(self, db_name, tbl_name, col_name): """ @@ -4264,7 +4265,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o3 if result.o4 is not None: raise result.o4 - raise TApplicationException(TApplicationException.MISSING_RESULT, "delete_table_column_statistics failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "delete_table_column_statistics failed: unknown result") def create_function(self, func): """ @@ -4408,7 +4409,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_functions failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_functions failed: unknown result") def get_function(self, dbName, funcName): """ @@ -4445,7 +4446,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_function failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_function failed: unknown result") def get_all_functions(self): self.send_get_all_functions() @@ -4473,7 +4474,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_all_functions failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_all_functions failed: unknown result") def create_role(self, role): """ @@ -4506,7 +4507,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "create_role failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "create_role failed: unknown result") def drop_role(self, role_name): """ @@ -4539,7 +4540,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_role failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_role failed: unknown result") def get_role_names(self): self.send_get_role_names() @@ -4567,7 +4568,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_role_names failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_role_names failed: unknown result") def grant_role(self, role_name, principal_name, principal_type, grantor, grantorType, grant_option): """ @@ -4610,7 +4611,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "grant_role failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "grant_role failed: unknown result") def revoke_role(self, role_name, principal_name, principal_type): """ @@ -4647,7 +4648,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "revoke_role failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "revoke_role failed: unknown result") def list_roles(self, principal_name, principal_type): """ @@ -4682,7 +4683,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "list_roles failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "list_roles failed: unknown result") def grant_revoke_role(self, request): """ @@ -4715,7 +4716,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "grant_revoke_role failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "grant_revoke_role failed: unknown result") def get_principals_in_role(self, request): """ @@ -4748,7 +4749,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_principals_in_role failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_principals_in_role failed: unknown result") def get_role_grants_for_principal(self, request): """ @@ -4781,7 +4782,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_role_grants_for_principal failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_role_grants_for_principal failed: unknown result") def get_privilege_set(self, hiveObject, user_name, group_names): """ @@ -4818,7 +4819,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_privilege_set failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_privilege_set failed: unknown result") def list_privileges(self, principal_name, principal_type, hiveObject): """ @@ -4855,7 +4856,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "list_privileges failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "list_privileges failed: unknown result") def grant_privileges(self, privileges): """ @@ -4888,7 +4889,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "grant_privileges failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "grant_privileges failed: unknown result") def revoke_privileges(self, privileges): """ @@ -4921,7 +4922,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "revoke_privileges failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "revoke_privileges failed: unknown result") def grant_revoke_privileges(self, request): """ @@ -4954,7 +4955,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "grant_revoke_privileges failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "grant_revoke_privileges failed: unknown result") def set_ugi(self, user_name, group_names): """ @@ -4989,7 +4990,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "set_ugi failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "set_ugi failed: unknown result") def get_delegation_token(self, token_owner, renewer_kerberos_principal_name): """ @@ -5024,7 +5025,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_delegation_token failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_delegation_token failed: unknown result") def renew_delegation_token(self, token_str_form): """ @@ -5057,7 +5058,7 @@ class Client(fb303.FacebookService.Client, Iface): return result.success if result.o1 is not None: raise result.o1 - raise TApplicationException(TApplicationException.MISSING_RESULT, "renew_delegation_token failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "renew_delegation_token failed: unknown result") def cancel_delegation_token(self, token_str_form): """ @@ -5114,7 +5115,7 @@ class Client(fb303.FacebookService.Client, Iface): iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_open_txns failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_open_txns failed: unknown result") def get_open_txns_info(self): self.send_get_open_txns_info() @@ -5140,7 +5141,7 @@ class Client(fb303.FacebookService.Client, Iface): iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_open_txns_info failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_open_txns_info failed: unknown result") def open_txns(self, rqst): """ @@ -5171,7 +5172,7 @@ class Client(fb303.FacebookService.Client, Iface): iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "open_txns failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "open_txns failed: unknown result") def abort_txn(self, rqst): """ @@ -5270,7 +5271,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 if result.o2 is not None: raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "lock failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "lock failed: unknown result") def check_lock(self, rqst): """ @@ -5307,7 +5308,7 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 if result.o3 is not None: raise result.o3 - raise TApplicationException(TApplicationException.MISSING_RESULT, "check_lock failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "check_lock failed: unknown result") def unlock(self, rqst): """ @@ -5371,7 +5372,7 @@ class Client(fb303.FacebookService.Client, Iface): iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "show_locks failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "show_locks failed: unknown result") def heartbeat(self, ids): """ @@ -5437,7 +5438,7 @@ class Client(fb303.FacebookService.Client, Iface): iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "heartbeat_txn_range failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "heartbeat_txn_range failed: unknown result") def compact(self, rqst): """ @@ -5497,7 +5498,7 @@ class Client(fb303.FacebookService.Client, Iface): iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "show_compact failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "show_compact failed: unknown result") def add_dynamic_partitions(self, rqst): """ @@ -5561,7 +5562,7 @@ class Client(fb303.FacebookService.Client, Iface): iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_next_notification failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_next_notification failed: unknown result") def get_current_notificationEventId(self): self.send_get_current_notificationEventId() @@ -5587,7 +5588,7 @@ class Client(fb303.FacebookService.Client, Iface): iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_current_notificationEventId failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_current_notificationEventId failed: unknown result") def fire_listener_event(self, rqst): """ @@ -5618,7 +5619,7 @@ class Client(fb303.FacebookService.Client, Iface): iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "fire_listener_event failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "fire_listener_event failed: unknown result") def flushCache(self): self.send_flushCache() @@ -5673,7 +5674,7 @@ class Client(fb303.FacebookService.Client, Iface): iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_file_metadata_by_expr failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_file_metadata_by_expr failed: unknown result") def get_file_metadata(self, req): """ @@ -5704,7 +5705,7 @@ class Client(fb303.FacebookService.Client, Iface): iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_file_metadata failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_file_metadata failed: unknown result") def put_file_metadata(self, req): """ @@ -5735,7 +5736,7 @@ class Client(fb303.FacebookService.Client, Iface): iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "put_file_metadata failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "put_file_metadata failed: unknown result") def clear_file_metadata(self, req): """ @@ -5766,7 +5767,7 @@ class Client(fb303.FacebookService.Client, Iface): iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "clear_file_metadata failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "clear_file_metadata failed: unknown result") class Processor(fb303.FacebookService.Processor, Iface, TProcessor): @@ -5924,9 +5925,17 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = getMetaConf_result() try: result.success = self._handler.getMetaConf(args.key) - except MetaException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - oprot.writeMessageBegin("getMetaConf", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("getMetaConf", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -5938,9 +5947,17 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = setMetaConf_result() try: self._handler.setMetaConf(args.key, args.value) - except MetaException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - oprot.writeMessageBegin("setMetaConf", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("setMetaConf", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -5952,13 +5969,23 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = create_database_result() try: self._handler.create_database(args.database) - except AlreadyExistsException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except AlreadyExistsException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except InvalidObjectException, o2: + except InvalidObjectException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except MetaException, o3: + except MetaException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("create_database", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("create_database", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -5970,11 +5997,20 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = get_database_result() try: result.success = self._handler.get_database(args.name) - except NoSuchObjectException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except NoSuchObjectException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except MetaException, o2: + except MetaException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - oprot.writeMessageBegin("get_database", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_database", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -5986,13 +6022,23 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = drop_database_result() try: self._handler.drop_database(args.name, args.deleteData, args.cascade) - except NoSuchObjectException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except NoSuchObjectException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except InvalidOperationException, o2: + except InvalidOperationException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except MetaException, o3: + except MetaException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("drop_database", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("drop_database", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6004,9 +6050,17 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = get_databases_result() try: result.success = self._handler.get_databases(args.pattern) - except MetaException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - oprot.writeMessageBegin("get_databases", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_databases", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6018,9 +6072,17 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = get_all_databases_result() try: result.success = self._handler.get_all_databases() - except MetaException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - oprot.writeMessageBegin("get_all_databases", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_all_databases", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6032,11 +6094,20 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = alter_database_result() try: self._handler.alter_database(args.dbname, args.db) - except MetaException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except NoSuchObjectException, o2: + except NoSuchObjectException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - oprot.writeMessageBegin("alter_database", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("alter_database", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6048,11 +6119,20 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = get_type_result() try: result.success = self._handler.get_type(args.name) - except MetaException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except NoSuchObjectException, o2: + except NoSuchObjectException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - oprot.writeMessageBegin("get_type", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_type", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6064,13 +6144,23 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = create_type_result() try: result.success = self._handler.create_type(args.type) - except AlreadyExistsException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except AlreadyExistsException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except InvalidObjectException, o2: + except InvalidObjectException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except MetaException, o3: + except MetaException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("create_type", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("create_type", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6082,11 +6172,20 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = drop_type_result() try: result.success = self._handler.drop_type(args.type) - except MetaException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except NoSuchObjectException, o2: + except NoSuchObjectException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - oprot.writeMessageBegin("drop_type", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("drop_type", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6098,9 +6197,17 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = get_type_all_result() try: result.success = self._handler.get_type_all(args.name) - except MetaException, o2: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - oprot.writeMessageBegin("get_type_all", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_type_all", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6112,13 +6219,23 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = get_fields_result() try: result.success = self._handler.get_fields(args.db_name, args.table_name) - except MetaException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except UnknownTableException, o2: + except UnknownTableException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except UnknownDBException, o3: + except UnknownDBException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("get_fields", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_fields", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6130,13 +6247,23 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = get_fields_with_environment_context_result() try: result.success = self._handler.get_fields_with_environment_context(args.db_name, args.table_name, args.environment_context) - except MetaException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except UnknownTableException, o2: + except UnknownTableException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except UnknownDBException, o3: + except UnknownDBException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("get_fields_with_environment_context", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_fields_with_environment_context", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6148,13 +6275,23 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = get_schema_result() try: result.success = self._handler.get_schema(args.db_name, args.table_name) - except MetaException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except UnknownTableException, o2: + except UnknownTableException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except UnknownDBException, o3: + except UnknownDBException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("get_schema", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_schema", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6166,13 +6303,23 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = get_schema_with_environment_context_result() try: result.success = self._handler.get_schema_with_environment_context(args.db_name, args.table_name, args.environment_context) - except MetaException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except UnknownTableException, o2: + except UnknownTableException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except UnknownDBException, o3: + except UnknownDBException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("get_schema_with_environment_context", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_schema_with_environment_context", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6184,15 +6331,26 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = create_table_result() try: self._handler.create_table(args.tbl) - except AlreadyExistsException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except AlreadyExistsException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except InvalidObjectException, o2: + except InvalidObjectException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except MetaException, o3: + except MetaException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - except NoSuchObjectException, o4: + except NoSuchObjectException as o4: + msg_type = TMessageType.REPLY result.o4 = o4 - oprot.writeMessageBegin("create_table", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("create_table", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6204,15 +6362,26 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = create_table_with_environment_context_result() try: self._handler.create_table_with_environment_context(args.tbl, args.environment_context) - except AlreadyExistsException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except AlreadyExistsException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except InvalidObjectException, o2: + except InvalidObjectException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except MetaException, o3: + except MetaException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - except NoSuchObjectException, o4: + except NoSuchObjectException as o4: + msg_type = TMessageType.REPLY result.o4 = o4 - oprot.writeMessageBegin("create_table_with_environment_context", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("create_table_with_environment_context", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6224,11 +6393,20 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = drop_table_result() try: self._handler.drop_table(args.dbname, args.name, args.deleteData) - except NoSuchObjectException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except NoSuchObjectException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except MetaException, o3: + except MetaException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("drop_table", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("drop_table", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6240,11 +6418,20 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = drop_table_with_environment_context_result() try: self._handler.drop_table_with_environment_context(args.dbname, args.name, args.deleteData, args.environment_context) - except NoSuchObjectException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except NoSuchObjectException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except MetaException, o3: + except MetaException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("drop_table_with_environment_context", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("drop_table_with_environment_context", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6256,9 +6443,17 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = get_tables_result() try: result.success = self._handler.get_tables(args.db_name, args.pattern) - except MetaException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - oprot.writeMessageBegin("get_tables", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_tables", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6270,9 +6465,17 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = get_all_tables_result() try: result.success = self._handler.get_all_tables(args.db_name) - except MetaException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - oprot.writeMessageBegin("get_all_tables", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_all_tables", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6284,11 +6487,20 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = get_table_result() try: result.success = self._handler.get_table(args.dbname, args.tbl_name) - except MetaException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except NoSuchObjectException, o2: + except NoSuchObjectException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - oprot.writeMessageBegin("get_table", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_table", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6300,13 +6512,23 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = get_table_objects_by_name_result() try: result.success = self._handler.get_table_objects_by_name(args.dbname, args.tbl_names) - except MetaException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except InvalidOperationException, o2: + except InvalidOperationException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except UnknownDBException, o3: + except UnknownDBException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("get_table_objects_by_name", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_table_objects_by_name", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6318,13 +6540,23 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = get_table_names_by_filter_result() try: result.success = self._handler.get_table_names_by_filter(args.dbname, args.filter, args.max_tables) - except MetaException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except InvalidOperationException, o2: + except InvalidOperationException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except UnknownDBException, o3: + except UnknownDBException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("get_table_names_by_filter", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_table_names_by_filter", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6336,11 +6568,20 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = alter_table_result() try: self._handler.alter_table(args.dbname, args.tbl_name, args.new_tbl) - except InvalidOperationException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except InvalidOperationException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except MetaException, o2: + except MetaException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - oprot.writeMessageBegin("alter_table", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("alter_table", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6352,11 +6593,20 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = alter_table_with_environment_context_result() try: self._handler.alter_table_with_environment_context(args.dbname, args.tbl_name, args.new_tbl, args.environment_context) - except InvalidOperationException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except InvalidOperationException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except MetaException, o2: + except MetaException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - oprot.writeMessageBegin("alter_table_with_environment_context", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("alter_table_with_environment_context", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6368,11 +6618,20 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = alter_table_with_cascade_result() try: self._handler.alter_table_with_cascade(args.dbname, args.tbl_name, args.new_tbl, args.cascade) - except InvalidOperationException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except InvalidOperationException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except MetaException, o2: + except MetaException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - oprot.writeMessageBegin("alter_table_with_cascade", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("alter_table_with_cascade", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6384,13 +6643,23 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = add_partition_result() try: result.success = self._handler.add_partition(args.new_part) - except InvalidObjectException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except InvalidObjectException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except AlreadyExistsException, o2: + except AlreadyExistsException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except MetaException, o3: + except MetaException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("add_partition", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("add_partition", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6402,13 +6671,23 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = add_partition_with_environment_context_result() try: result.success = self._handler.add_partition_with_environment_context(args.new_part, args.environment_context) - except InvalidObjectException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except InvalidObjectException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except AlreadyExistsException, o2: + except AlreadyExistsException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except MetaException, o3: + except MetaException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("add_partition_with_environment_context", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("add_partition_with_environment_context", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6420,13 +6699,23 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = add_partitions_result() try: result.success = self._handler.add_partitions(args.new_parts) - except InvalidObjectException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except InvalidObjectException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except AlreadyExistsException, o2: + except AlreadyExistsException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except MetaException, o3: + except MetaException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("add_partitions", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("add_partitions", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6438,13 +6727,23 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = add_partitions_pspec_result() try: result.success = self._handler.add_partitions_pspec(args.new_parts) - except InvalidObjectException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except InvalidObjectException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except AlreadyExistsException, o2: + except AlreadyExistsException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except MetaException, o3: + except MetaException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("add_partitions_pspec", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("add_partitions_pspec", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6456,13 +6755,23 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = append_partition_result() try: result.success = self._handler.append_partition(args.db_name, args.tbl_name, args.part_vals) - except InvalidObjectException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except InvalidObjectException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except AlreadyExistsException, o2: + except AlreadyExistsException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except MetaException, o3: + except MetaException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("append_partition", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("append_partition", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6474,13 +6783,23 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = add_partitions_req_result() try: result.success = self._handler.add_partitions_req(args.request) - except InvalidObjectException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except InvalidObjectException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except AlreadyExistsException, o2: + except AlreadyExistsException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except MetaException, o3: + except MetaException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("add_partitions_req", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("add_partitions_req", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6492,13 +6811,23 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = append_partition_with_environment_context_result() try: result.success = self._handler.append_partition_with_environment_context(args.db_name, args.tbl_name, args.part_vals, args.environment_context) - except InvalidObjectException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except InvalidObjectException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except AlreadyExistsException, o2: + except AlreadyExistsException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except MetaException, o3: + except MetaException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("append_partition_with_environment_context", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("append_partition_with_environment_context", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6510,13 +6839,23 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = append_partition_by_name_result() try: result.success = self._handler.append_partition_by_name(args.db_name, args.tbl_name, args.part_name) - except InvalidObjectException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except InvalidObjectException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except AlreadyExistsException, o2: + except AlreadyExistsException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except MetaException, o3: + except MetaException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("append_partition_by_name", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("append_partition_by_name", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6528,13 +6867,23 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = append_partition_by_name_with_environment_context_result() try: result.success = self._handler.append_partition_by_name_with_environment_context(args.db_name, args.tbl_name, args.part_name, args.environment_context) - except InvalidObjectException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except InvalidObjectException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except AlreadyExistsException, o2: + except AlreadyExistsException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - except MetaException, o3: + except MetaException as o3: + msg_type = TMessageType.REPLY result.o3 = o3 - oprot.writeMessageBegin("append_partition_by_name_with_environment_context", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("append_partition_by_name_with_environment_context", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6546,11 +6895,20 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = drop_partition_result() try: result.success = self._handler.drop_partition(args.db_name, args.tbl_name, args.part_vals, args.deleteData) - except NoSuchObjectException, o1: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except NoSuchObjectException as o1: + msg_type = TMessageType.REPLY result.o1 = o1 - except MetaException, o2: + except MetaException as o2: + msg_type = TMessageType.REPLY result.o2 = o2 - oprot.writeMessageBegin("drop_partition", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("drop_partition", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -6562,11 +6920,20 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): result = drop_partition_with_environment_context_result() try: result.success = self._handler.drop_partition_with_environment_context(args.db_name, args.tbl_name, args.part_vals, args.deleteData, args.environment_context) - except NoSuchObjectException, o1: + msg_type = TMe
<TRUNCATED>