OmniSciDB  6686921089
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
OmniSci.py
Go to the documentation of this file.
1 #
2 # Autogenerated by Thrift Compiler (0.13.0)
3 #
4 # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
5 #
6 # options string: py
7 #
8 
9 from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
10 from thrift.protocol.TProtocol import TProtocolException
11 from thrift.TRecursive import fix_spec
12 
13 import sys
14 import logging
15 from .ttypes import *
16 from thrift.Thrift import TProcessor
17 from thrift.transport import TTransport
18 all_structs = []
19 
20 
21 class Iface(object):
22  def connect(self, user, passwd, dbname):
23  """
24  Parameters:
25  - user
26  - passwd
27  - dbname
28 
29  """
30  pass
31 
32  def krb5_connect(self, inputToken, dbname):
33  """
34  Parameters:
35  - inputToken
36  - dbname
37 
38  """
39  pass
40 
41  def disconnect(self, session):
42  """
43  Parameters:
44  - session
45 
46  """
47  pass
48 
49  def switch_database(self, session, dbname):
50  """
51  Parameters:
52  - session
53  - dbname
54 
55  """
56  pass
57 
58  def clone_session(self, session):
59  """
60  Parameters:
61  - session
62 
63  """
64  pass
65 
66  def get_server_status(self, session):
67  """
68  Parameters:
69  - session
70 
71  """
72  pass
73 
74  def get_status(self, session):
75  """
76  Parameters:
77  - session
78 
79  """
80  pass
81 
82  def get_hardware_info(self, session):
83  """
84  Parameters:
85  - session
86 
87  """
88  pass
89 
90  def get_tables(self, session):
91  """
92  Parameters:
93  - session
94 
95  """
96  pass
97 
98  def get_tables_for_database(self, session, database_name):
99  """
100  Parameters:
101  - session
102  - database_name
103 
104  """
105  pass
106 
107  def get_physical_tables(self, session):
108  """
109  Parameters:
110  - session
111 
112  """
113  pass
114 
115  def get_views(self, session):
116  """
117  Parameters:
118  - session
119 
120  """
121  pass
122 
123  def get_tables_meta(self, session):
124  """
125  Parameters:
126  - session
127 
128  """
129  pass
130 
131  def get_table_details(self, session, table_name):
132  """
133  Parameters:
134  - session
135  - table_name
136 
137  """
138  pass
139 
140  def get_table_details_for_database(self, session, table_name, database_name):
141  """
142  Parameters:
143  - session
144  - table_name
145  - database_name
146 
147  """
148  pass
149 
150  def get_internal_table_details(self, session, table_name):
151  """
152  Parameters:
153  - session
154  - table_name
155 
156  """
157  pass
158 
159  def get_internal_table_details_for_database(self, session, table_name, database_name):
160  """
161  Parameters:
162  - session
163  - table_name
164  - database_name
165 
166  """
167  pass
168 
169  def get_users(self, session):
170  """
171  Parameters:
172  - session
173 
174  """
175  pass
176 
177  def get_databases(self, session):
178  """
179  Parameters:
180  - session
181 
182  """
183  pass
184 
185  def get_version(self):
186  pass
187 
188  def start_heap_profile(self, session):
189  """
190  Parameters:
191  - session
192 
193  """
194  pass
195 
196  def stop_heap_profile(self, session):
197  """
198  Parameters:
199  - session
200 
201  """
202  pass
203 
204  def get_heap_profile(self, session):
205  """
206  Parameters:
207  - session
208 
209  """
210  pass
211 
212  def get_memory(self, session, memory_level):
213  """
214  Parameters:
215  - session
216  - memory_level
217 
218  """
219  pass
220 
221  def clear_cpu_memory(self, session):
222  """
223  Parameters:
224  - session
225 
226  """
227  pass
228 
229  def clear_gpu_memory(self, session):
230  """
231  Parameters:
232  - session
233 
234  """
235  pass
236 
237  def set_cur_session(self, parent_session, leaf_session, start_time_str, label, for_running_query_kernel):
238  """
239  Parameters:
240  - parent_session
241  - leaf_session
242  - start_time_str
243  - label
244  - for_running_query_kernel
245 
246  """
247  pass
248 
249  def invalidate_cur_session(self, parent_session, leaf_session, start_time_str, label, for_running_query_kernel):
250  """
251  Parameters:
252  - parent_session
253  - leaf_session
254  - start_time_str
255  - label
256  - for_running_query_kernel
257 
258  """
259  pass
260 
261  def set_table_epoch(self, session, db_id, table_id, new_epoch):
262  """
263  Parameters:
264  - session
265  - db_id
266  - table_id
267  - new_epoch
268 
269  """
270  pass
271 
272  def set_table_epoch_by_name(self, session, table_name, new_epoch):
273  """
274  Parameters:
275  - session
276  - table_name
277  - new_epoch
278 
279  """
280  pass
281 
282  def get_table_epoch(self, session, db_id, table_id):
283  """
284  Parameters:
285  - session
286  - db_id
287  - table_id
288 
289  """
290  pass
291 
292  def get_table_epoch_by_name(self, session, table_name):
293  """
294  Parameters:
295  - session
296  - table_name
297 
298  """
299  pass
300 
301  def get_table_epochs(self, session, db_id, table_id):
302  """
303  Parameters:
304  - session
305  - db_id
306  - table_id
307 
308  """
309  pass
310 
311  def set_table_epochs(self, session, db_id, table_epochs):
312  """
313  Parameters:
314  - session
315  - db_id
316  - table_epochs
317 
318  """
319  pass
320 
321  def get_session_info(self, session):
322  """
323  Parameters:
324  - session
325 
326  """
327  pass
328 
329  def sql_execute(self, session, query, column_format, nonce, first_n, at_most_n):
330  """
331  Parameters:
332  - session
333  - query
334  - column_format
335  - nonce
336  - first_n
337  - at_most_n
338 
339  """
340  pass
341 
342  def sql_execute_df(self, session, query, device_type, device_id, first_n, transport_method):
343  """
344  Parameters:
345  - session
346  - query
347  - device_type
348  - device_id
349  - first_n
350  - transport_method
351 
352  """
353  pass
354 
355  def sql_execute_gdf(self, session, query, device_id, first_n):
356  """
357  Parameters:
358  - session
359  - query
360  - device_id
361  - first_n
362 
363  """
364  pass
365 
366  def deallocate_df(self, session, df, device_type, device_id):
367  """
368  Parameters:
369  - session
370  - df
371  - device_type
372  - device_id
373 
374  """
375  pass
376 
377  def interrupt(self, query_session, interrupt_session):
378  """
379  Parameters:
380  - query_session
381  - interrupt_session
382 
383  """
384  pass
385 
386  def sql_validate(self, session, query):
387  """
388  Parameters:
389  - session
390  - query
391 
392  """
393  pass
394 
395  def get_completion_hints(self, session, sql, cursor):
396  """
397  Parameters:
398  - session
399  - sql
400  - cursor
401 
402  """
403  pass
404 
405  def set_execution_mode(self, session, mode):
406  """
407  Parameters:
408  - session
409  - mode
410 
411  """
412  pass
413 
414  def render_vega(self, session, widget_id, vega_json, compression_level, nonce):
415  """
416  Parameters:
417  - session
418  - widget_id
419  - vega_json
420  - compression_level
421  - nonce
422 
423  """
424  pass
425 
426  def get_result_row_for_pixel(self, session, widget_id, pixel, table_col_names, column_format, pixelRadius, nonce):
427  """
428  Parameters:
429  - session
430  - widget_id
431  - pixel
432  - table_col_names
433  - column_format
434  - pixelRadius
435  - nonce
436 
437  """
438  pass
439 
440  def create_custom_expression(self, session, custom_expression):
441  """
442  Parameters:
443  - session
444  - custom_expression
445 
446  """
447  pass
448 
449  def get_custom_expressions(self, session):
450  """
451  Parameters:
452  - session
453 
454  """
455  pass
456 
457  def update_custom_expression(self, session, id, expression_json):
458  """
459  Parameters:
460  - session
461  - id
462  - expression_json
463 
464  """
465  pass
466 
467  def delete_custom_expressions(self, session, custom_expression_ids, do_soft_delete):
468  """
469  Parameters:
470  - session
471  - custom_expression_ids
472  - do_soft_delete
473 
474  """
475  pass
476 
477  def get_dashboard(self, session, dashboard_id):
478  """
479  Parameters:
480  - session
481  - dashboard_id
482 
483  """
484  pass
485 
486  def get_dashboards(self, session):
487  """
488  Parameters:
489  - session
490 
491  """
492  pass
493 
494  def create_dashboard(self, session, dashboard_name, dashboard_state, image_hash, dashboard_metadata):
495  """
496  Parameters:
497  - session
498  - dashboard_name
499  - dashboard_state
500  - image_hash
501  - dashboard_metadata
502 
503  """
504  pass
505 
506  def replace_dashboard(self, session, dashboard_id, dashboard_name, dashboard_owner, dashboard_state, image_hash, dashboard_metadata):
507  """
508  Parameters:
509  - session
510  - dashboard_id
511  - dashboard_name
512  - dashboard_owner
513  - dashboard_state
514  - image_hash
515  - dashboard_metadata
516 
517  """
518  pass
519 
520  def delete_dashboard(self, session, dashboard_id):
521  """
522  Parameters:
523  - session
524  - dashboard_id
525 
526  """
527  pass
528 
529  def share_dashboards(self, session, dashboard_ids, groups, permissions):
530  """
531  Parameters:
532  - session
533  - dashboard_ids
534  - groups
535  - permissions
536 
537  """
538  pass
539 
540  def delete_dashboards(self, session, dashboard_ids):
541  """
542  Parameters:
543  - session
544  - dashboard_ids
545 
546  """
547  pass
548 
549  def share_dashboard(self, session, dashboard_id, groups, objects, permissions, grant_role):
550  """
551  Parameters:
552  - session
553  - dashboard_id
554  - groups
555  - objects
556  - permissions
557  - grant_role
558 
559  """
560  pass
561 
562  def unshare_dashboard(self, session, dashboard_id, groups, objects, permissions):
563  """
564  Parameters:
565  - session
566  - dashboard_id
567  - groups
568  - objects
569  - permissions
570 
571  """
572  pass
573 
574  def unshare_dashboards(self, session, dashboard_ids, groups, permissions):
575  """
576  Parameters:
577  - session
578  - dashboard_ids
579  - groups
580  - permissions
581 
582  """
583  pass
584 
585  def get_dashboard_grantees(self, session, dashboard_id):
586  """
587  Parameters:
588  - session
589  - dashboard_id
590 
591  """
592  pass
593 
594  def get_link_view(self, session, link):
595  """
596  Parameters:
597  - session
598  - link
599 
600  """
601  pass
602 
603  def create_link(self, session, view_state, view_metadata):
604  """
605  Parameters:
606  - session
607  - view_state
608  - view_metadata
609 
610  """
611  pass
612 
613  def load_table_binary(self, session, table_name, rows, column_names):
614  """
615  Parameters:
616  - session
617  - table_name
618  - rows
619  - column_names
620 
621  """
622  pass
623 
624  def load_table_binary_columnar(self, session, table_name, cols, column_names):
625  """
626  Parameters:
627  - session
628  - table_name
629  - cols
630  - column_names
631 
632  """
633  pass
634 
635  def load_table_binary_columnar_polys(self, session, table_name, cols, column_names, assign_render_groups):
636  """
637  Parameters:
638  - session
639  - table_name
640  - cols
641  - column_names
642  - assign_render_groups
643 
644  """
645  pass
646 
647  def load_table_binary_arrow(self, session, table_name, arrow_stream, use_column_names):
648  """
649  Parameters:
650  - session
651  - table_name
652  - arrow_stream
653  - use_column_names
654 
655  """
656  pass
657 
658  def load_table(self, session, table_name, rows, column_names):
659  """
660  Parameters:
661  - session
662  - table_name
663  - rows
664  - column_names
665 
666  """
667  pass
668 
669  def detect_column_types(self, session, file_name, copy_params):
670  """
671  Parameters:
672  - session
673  - file_name
674  - copy_params
675 
676  """
677  pass
678 
679  def create_table(self, session, table_name, row_desc, file_type, create_params):
680  """
681  Parameters:
682  - session
683  - table_name
684  - row_desc
685  - file_type
686  - create_params
687 
688  """
689  pass
690 
691  def import_table(self, session, table_name, file_name, copy_params):
692  """
693  Parameters:
694  - session
695  - table_name
696  - file_name
697  - copy_params
698 
699  """
700  pass
701 
702  def import_geo_table(self, session, table_name, file_name, copy_params, row_desc, create_params):
703  """
704  Parameters:
705  - session
706  - table_name
707  - file_name
708  - copy_params
709  - row_desc
710  - create_params
711 
712  """
713  pass
714 
715  def import_table_status(self, session, import_id):
716  """
717  Parameters:
718  - session
719  - import_id
720 
721  """
722  pass
723 
724  def get_first_geo_file_in_archive(self, session, archive_path, copy_params):
725  """
726  Parameters:
727  - session
728  - archive_path
729  - copy_params
730 
731  """
732  pass
733 
734  def get_all_files_in_archive(self, session, archive_path, copy_params):
735  """
736  Parameters:
737  - session
738  - archive_path
739  - copy_params
740 
741  """
742  pass
743 
744  def get_layers_in_geo_file(self, session, file_name, copy_params):
745  """
746  Parameters:
747  - session
748  - file_name
749  - copy_params
750 
751  """
752  pass
753 
754  def query_get_outer_fragment_count(self, session, query):
755  """
756  Parameters:
757  - session
758  - query
759 
760  """
761  pass
762 
763  def check_table_consistency(self, session, table_id):
764  """
765  Parameters:
766  - session
767  - table_id
768 
769  """
770  pass
771 
772  def start_query(self, leaf_session, parent_session, query_ra, start_time_str, just_explain, outer_fragment_indices):
773  """
774  Parameters:
775  - leaf_session
776  - parent_session
777  - query_ra
778  - start_time_str
779  - just_explain
780  - outer_fragment_indices
781 
782  """
783  pass
784 
785  def execute_query_step(self, pending_query, subquery_id, start_time_str):
786  """
787  Parameters:
788  - pending_query
789  - subquery_id
790  - start_time_str
791 
792  """
793  pass
794 
795  def broadcast_serialized_rows(self, serialized_rows, row_desc, query_id, subquery_id, is_final_subquery_result):
796  """
797  Parameters:
798  - serialized_rows
799  - row_desc
800  - query_id
801  - subquery_id
802  - is_final_subquery_result
803 
804  """
805  pass
806 
807  def start_render_query(self, session, widget_id, node_idx, vega_json):
808  """
809  Parameters:
810  - session
811  - widget_id
812  - node_idx
813  - vega_json
814 
815  """
816  pass
817 
818  def execute_next_render_step(self, pending_render, merged_data):
819  """
820  Parameters:
821  - pending_render
822  - merged_data
823 
824  """
825  pass
826 
827  def insert_data(self, session, insert_data):
828  """
829  Parameters:
830  - session
831  - insert_data
832 
833  """
834  pass
835 
836  def checkpoint(self, session, table_id):
837  """
838  Parameters:
839  - session
840  - table_id
841 
842  """
843  pass
844 
845  def get_roles(self, session):
846  """
847  Parameters:
848  - session
849 
850  """
851  pass
852 
853  def get_db_objects_for_grantee(self, session, roleName):
854  """
855  Parameters:
856  - session
857  - roleName
858 
859  """
860  pass
861 
862  def get_db_object_privs(self, session, objectName, type):
863  """
864  Parameters:
865  - session
866  - objectName
867  - type
868 
869  """
870  pass
871 
872  def get_all_roles_for_user(self, session, userName):
873  """
874  Parameters:
875  - session
876  - userName
877 
878  """
879  pass
880 
881  def has_role(self, session, granteeName, roleName):
882  """
883  Parameters:
884  - session
885  - granteeName
886  - roleName
887 
888  """
889  pass
890 
891  def has_object_privilege(self, session, granteeName, ObjectName, objectType, permissions):
892  """
893  Parameters:
894  - session
895  - granteeName
896  - ObjectName
897  - objectType
898  - permissions
899 
900  """
901  pass
902 
903  def set_license_key(self, session, key, nonce):
904  """
905  Parameters:
906  - session
907  - key
908  - nonce
909 
910  """
911  pass
912 
913  def get_license_claims(self, session, nonce):
914  """
915  Parameters:
916  - session
917  - nonce
918 
919  """
920  pass
921 
922  def get_device_parameters(self, session):
923  """
924  Parameters:
925  - session
926 
927  """
928  pass
929 
930  def register_runtime_extension_functions(self, session, udfs, udtfs, device_ir_map):
931  """
932  Parameters:
933  - session
934  - udfs
935  - udtfs
936  - device_ir_map
937 
938  """
939  pass
940 
941 
942 class Client(Iface):
943  def __init__(self, iprot, oprot=None):
944  self._iprot = self._oprot = iprot
945  if oprot is not None:
946  self._oprot = oprot
947  self._seqid = 0
948 
949  def connect(self, user, passwd, dbname):
950  """
951  Parameters:
952  - user
953  - passwd
954  - dbname
955 
956  """
957  self.send_connect(user, passwd, dbname)
958  return self.recv_connect()
959 
960  def send_connect(self, user, passwd, dbname):
961  self._oprot.writeMessageBegin('connect', TMessageType.CALL, self._seqid)
962  args = connect_args()
963  args.user = user
964  args.passwd = passwd
965  args.dbname = dbname
966  args.write(self._oprot)
967  self._oprot.writeMessageEnd()
968  self._oprot.trans.flush()
969 
970  def recv_connect(self):
971  iprot = self._iprot
972  (fname, mtype, rseqid) = iprot.readMessageBegin()
973  if mtype == TMessageType.EXCEPTION:
974  x = TApplicationException()
975  x.read(iprot)
976  iprot.readMessageEnd()
977  raise x
978  result = connect_result()
979  result.read(iprot)
980  iprot.readMessageEnd()
981  if result.success is not None:
982  return result.success
983  if result.e is not None:
984  raise result.e
985  raise TApplicationException(TApplicationException.MISSING_RESULT, "connect failed: unknown result")
986 
987  def krb5_connect(self, inputToken, dbname):
988  """
989  Parameters:
990  - inputToken
991  - dbname
992 
993  """
994  self.send_krb5_connect(inputToken, dbname)
995  return self.recv_krb5_connect()
996 
997  def send_krb5_connect(self, inputToken, dbname):
998  self._oprot.writeMessageBegin('krb5_connect', TMessageType.CALL, self._seqid)
999  args = krb5_connect_args()
1000  args.inputToken = inputToken
1001  args.dbname = dbname
1002  args.write(self._oprot)
1003  self._oprot.writeMessageEnd()
1004  self._oprot.trans.flush()
1005 
1007  iprot = self._iprot
1008  (fname, mtype, rseqid) = iprot.readMessageBegin()
1009  if mtype == TMessageType.EXCEPTION:
1010  x = TApplicationException()
1011  x.read(iprot)
1012  iprot.readMessageEnd()
1013  raise x
1014  result = krb5_connect_result()
1015  result.read(iprot)
1016  iprot.readMessageEnd()
1017  if result.success is not None:
1018  return result.success
1019  if result.e is not None:
1020  raise result.e
1021  raise TApplicationException(TApplicationException.MISSING_RESULT, "krb5_connect failed: unknown result")
1022 
1023  def disconnect(self, session):
1024  """
1025  Parameters:
1026  - session
1027 
1028  """
1029  self.send_disconnect(session)
1030  self.recv_disconnect()
1031 
1032  def send_disconnect(self, session):
1033  self._oprot.writeMessageBegin('disconnect', TMessageType.CALL, self._seqid)
1034  args = disconnect_args()
1035  args.session = session
1036  args.write(self._oprot)
1037  self._oprot.writeMessageEnd()
1038  self._oprot.trans.flush()
1039 
1040  def recv_disconnect(self):
1041  iprot = self._iprot
1042  (fname, mtype, rseqid) = iprot.readMessageBegin()
1043  if mtype == TMessageType.EXCEPTION:
1044  x = TApplicationException()
1045  x.read(iprot)
1046  iprot.readMessageEnd()
1047  raise x
1048  result = disconnect_result()
1049  result.read(iprot)
1050  iprot.readMessageEnd()
1051  if result.e is not None:
1052  raise result.e
1053  return
1054 
1055  def switch_database(self, session, dbname):
1056  """
1057  Parameters:
1058  - session
1059  - dbname
1060 
1061  """
1062  self.send_switch_database(session, dbname)
1063  self.recv_switch_database()
1064 
1065  def send_switch_database(self, session, dbname):
1066  self._oprot.writeMessageBegin('switch_database', TMessageType.CALL, self._seqid)
1067  args = switch_database_args()
1068  args.session = session
1069  args.dbname = dbname
1070  args.write(self._oprot)
1071  self._oprot.writeMessageEnd()
1072  self._oprot.trans.flush()
1073 
1075  iprot = self._iprot
1076  (fname, mtype, rseqid) = iprot.readMessageBegin()
1077  if mtype == TMessageType.EXCEPTION:
1078  x = TApplicationException()
1079  x.read(iprot)
1080  iprot.readMessageEnd()
1081  raise x
1082  result = switch_database_result()
1083  result.read(iprot)
1084  iprot.readMessageEnd()
1085  if result.e is not None:
1086  raise result.e
1087  return
1088 
1089  def clone_session(self, session):
1090  """
1091  Parameters:
1092  - session
1093 
1094  """
1095  self.send_clone_session(session)
1096  return self.recv_clone_session()
1097 
1098  def send_clone_session(self, session):
1099  self._oprot.writeMessageBegin('clone_session', TMessageType.CALL, self._seqid)
1100  args = clone_session_args()
1101  args.session = session
1102  args.write(self._oprot)
1103  self._oprot.writeMessageEnd()
1104  self._oprot.trans.flush()
1105 
1107  iprot = self._iprot
1108  (fname, mtype, rseqid) = iprot.readMessageBegin()
1109  if mtype == TMessageType.EXCEPTION:
1110  x = TApplicationException()
1111  x.read(iprot)
1112  iprot.readMessageEnd()
1113  raise x
1114  result = clone_session_result()
1115  result.read(iprot)
1116  iprot.readMessageEnd()
1117  if result.success is not None:
1118  return result.success
1119  if result.e is not None:
1120  raise result.e
1121  raise TApplicationException(TApplicationException.MISSING_RESULT, "clone_session failed: unknown result")
1122 
1123  def get_server_status(self, session):
1124  """
1125  Parameters:
1126  - session
1127 
1128  """
1129  self.send_get_server_status(session)
1130  return self.recv_get_server_status()
1131 
1132  def send_get_server_status(self, session):
1133  self._oprot.writeMessageBegin('get_server_status', TMessageType.CALL, self._seqid)
1134  args = get_server_status_args()
1135  args.session = session
1136  args.write(self._oprot)
1137  self._oprot.writeMessageEnd()
1138  self._oprot.trans.flush()
1139 
1141  iprot = self._iprot
1142  (fname, mtype, rseqid) = iprot.readMessageBegin()
1143  if mtype == TMessageType.EXCEPTION:
1144  x = TApplicationException()
1145  x.read(iprot)
1146  iprot.readMessageEnd()
1147  raise x
1148  result = get_server_status_result()
1149  result.read(iprot)
1150  iprot.readMessageEnd()
1151  if result.success is not None:
1152  return result.success
1153  if result.e is not None:
1154  raise result.e
1155  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_server_status failed: unknown result")
1156 
1157  def get_status(self, session):
1158  """
1159  Parameters:
1160  - session
1161 
1162  """
1163  self.send_get_status(session)
1164  return self.recv_get_status()
1165 
1166  def send_get_status(self, session):
1167  self._oprot.writeMessageBegin('get_status', TMessageType.CALL, self._seqid)
1168  args = get_status_args()
1169  args.session = session
1170  args.write(self._oprot)
1171  self._oprot.writeMessageEnd()
1172  self._oprot.trans.flush()
1173 
1174  def recv_get_status(self):
1175  iprot = self._iprot
1176  (fname, mtype, rseqid) = iprot.readMessageBegin()
1177  if mtype == TMessageType.EXCEPTION:
1178  x = TApplicationException()
1179  x.read(iprot)
1180  iprot.readMessageEnd()
1181  raise x
1182  result = get_status_result()
1183  result.read(iprot)
1184  iprot.readMessageEnd()
1185  if result.success is not None:
1186  return result.success
1187  if result.e is not None:
1188  raise result.e
1189  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_status failed: unknown result")
1190 
1191  def get_hardware_info(self, session):
1192  """
1193  Parameters:
1194  - session
1195 
1196  """
1197  self.send_get_hardware_info(session)
1198  return self.recv_get_hardware_info()
1199 
1200  def send_get_hardware_info(self, session):
1201  self._oprot.writeMessageBegin('get_hardware_info', TMessageType.CALL, self._seqid)
1202  args = get_hardware_info_args()
1203  args.session = session
1204  args.write(self._oprot)
1205  self._oprot.writeMessageEnd()
1206  self._oprot.trans.flush()
1207 
1209  iprot = self._iprot
1210  (fname, mtype, rseqid) = iprot.readMessageBegin()
1211  if mtype == TMessageType.EXCEPTION:
1212  x = TApplicationException()
1213  x.read(iprot)
1214  iprot.readMessageEnd()
1215  raise x
1216  result = get_hardware_info_result()
1217  result.read(iprot)
1218  iprot.readMessageEnd()
1219  if result.success is not None:
1220  return result.success
1221  if result.e is not None:
1222  raise result.e
1223  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_hardware_info failed: unknown result")
1224 
1225  def get_tables(self, session):
1226  """
1227  Parameters:
1228  - session
1229 
1230  """
1231  self.send_get_tables(session)
1232  return self.recv_get_tables()
1233 
1234  def send_get_tables(self, session):
1235  self._oprot.writeMessageBegin('get_tables', TMessageType.CALL, self._seqid)
1236  args = get_tables_args()
1237  args.session = session
1238  args.write(self._oprot)
1239  self._oprot.writeMessageEnd()
1240  self._oprot.trans.flush()
1241 
1242  def recv_get_tables(self):
1243  iprot = self._iprot
1244  (fname, mtype, rseqid) = iprot.readMessageBegin()
1245  if mtype == TMessageType.EXCEPTION:
1246  x = TApplicationException()
1247  x.read(iprot)
1248  iprot.readMessageEnd()
1249  raise x
1250  result = get_tables_result()
1251  result.read(iprot)
1252  iprot.readMessageEnd()
1253  if result.success is not None:
1254  return result.success
1255  if result.e is not None:
1256  raise result.e
1257  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_tables failed: unknown result")
1258 
1259  def get_tables_for_database(self, session, database_name):
1260  """
1261  Parameters:
1262  - session
1263  - database_name
1264 
1265  """
1266  self.send_get_tables_for_database(session, database_name)
1267  return self.recv_get_tables_for_database()
1268 
1269  def send_get_tables_for_database(self, session, database_name):
1270  self._oprot.writeMessageBegin('get_tables_for_database', TMessageType.CALL, self._seqid)
1272  args.session = session
1273  args.database_name = database_name
1274  args.write(self._oprot)
1275  self._oprot.writeMessageEnd()
1276  self._oprot.trans.flush()
1277 
1279  iprot = self._iprot
1280  (fname, mtype, rseqid) = iprot.readMessageBegin()
1281  if mtype == TMessageType.EXCEPTION:
1282  x = TApplicationException()
1283  x.read(iprot)
1284  iprot.readMessageEnd()
1285  raise x
1287  result.read(iprot)
1288  iprot.readMessageEnd()
1289  if result.success is not None:
1290  return result.success
1291  if result.e is not None:
1292  raise result.e
1293  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_tables_for_database failed: unknown result")
1294 
1295  def get_physical_tables(self, session):
1296  """
1297  Parameters:
1298  - session
1299 
1300  """
1301  self.send_get_physical_tables(session)
1302  return self.recv_get_physical_tables()
1303 
1304  def send_get_physical_tables(self, session):
1305  self._oprot.writeMessageBegin('get_physical_tables', TMessageType.CALL, self._seqid)
1306  args = get_physical_tables_args()
1307  args.session = session
1308  args.write(self._oprot)
1309  self._oprot.writeMessageEnd()
1310  self._oprot.trans.flush()
1311 
1313  iprot = self._iprot
1314  (fname, mtype, rseqid) = iprot.readMessageBegin()
1315  if mtype == TMessageType.EXCEPTION:
1316  x = TApplicationException()
1317  x.read(iprot)
1318  iprot.readMessageEnd()
1319  raise x
1320  result = get_physical_tables_result()
1321  result.read(iprot)
1322  iprot.readMessageEnd()
1323  if result.success is not None:
1324  return result.success
1325  if result.e is not None:
1326  raise result.e
1327  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_physical_tables failed: unknown result")
1328 
1329  def get_views(self, session):
1330  """
1331  Parameters:
1332  - session
1333 
1334  """
1335  self.send_get_views(session)
1336  return self.recv_get_views()
1337 
1338  def send_get_views(self, session):
1339  self._oprot.writeMessageBegin('get_views', TMessageType.CALL, self._seqid)
1340  args = get_views_args()
1341  args.session = session
1342  args.write(self._oprot)
1343  self._oprot.writeMessageEnd()
1344  self._oprot.trans.flush()
1345 
1346  def recv_get_views(self):
1347  iprot = self._iprot
1348  (fname, mtype, rseqid) = iprot.readMessageBegin()
1349  if mtype == TMessageType.EXCEPTION:
1350  x = TApplicationException()
1351  x.read(iprot)
1352  iprot.readMessageEnd()
1353  raise x
1354  result = get_views_result()
1355  result.read(iprot)
1356  iprot.readMessageEnd()
1357  if result.success is not None:
1358  return result.success
1359  if result.e is not None:
1360  raise result.e
1361  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_views failed: unknown result")
1362 
1363  def get_tables_meta(self, session):
1364  """
1365  Parameters:
1366  - session
1367 
1368  """
1369  self.send_get_tables_meta(session)
1370  return self.recv_get_tables_meta()
1371 
1372  def send_get_tables_meta(self, session):
1373  self._oprot.writeMessageBegin('get_tables_meta', TMessageType.CALL, self._seqid)
1374  args = get_tables_meta_args()
1375  args.session = session
1376  args.write(self._oprot)
1377  self._oprot.writeMessageEnd()
1378  self._oprot.trans.flush()
1379 
1381  iprot = self._iprot
1382  (fname, mtype, rseqid) = iprot.readMessageBegin()
1383  if mtype == TMessageType.EXCEPTION:
1384  x = TApplicationException()
1385  x.read(iprot)
1386  iprot.readMessageEnd()
1387  raise x
1388  result = get_tables_meta_result()
1389  result.read(iprot)
1390  iprot.readMessageEnd()
1391  if result.success is not None:
1392  return result.success
1393  if result.e is not None:
1394  raise result.e
1395  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_tables_meta failed: unknown result")
1396 
1397  def get_table_details(self, session, table_name):
1398  """
1399  Parameters:
1400  - session
1401  - table_name
1402 
1403  """
1404  self.send_get_table_details(session, table_name)
1405  return self.recv_get_table_details()
1406 
1407  def send_get_table_details(self, session, table_name):
1408  self._oprot.writeMessageBegin('get_table_details', TMessageType.CALL, self._seqid)
1409  args = get_table_details_args()
1410  args.session = session
1411  args.table_name = table_name
1412  args.write(self._oprot)
1413  self._oprot.writeMessageEnd()
1414  self._oprot.trans.flush()
1415 
1417  iprot = self._iprot
1418  (fname, mtype, rseqid) = iprot.readMessageBegin()
1419  if mtype == TMessageType.EXCEPTION:
1420  x = TApplicationException()
1421  x.read(iprot)
1422  iprot.readMessageEnd()
1423  raise x
1424  result = get_table_details_result()
1425  result.read(iprot)
1426  iprot.readMessageEnd()
1427  if result.success is not None:
1428  return result.success
1429  if result.e is not None:
1430  raise result.e
1431  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_details failed: unknown result")
1432 
1433  def get_table_details_for_database(self, session, table_name, database_name):
1434  """
1435  Parameters:
1436  - session
1437  - table_name
1438  - database_name
1439 
1440  """
1441  self.send_get_table_details_for_database(session, table_name, database_name)
1443 
1444  def send_get_table_details_for_database(self, session, table_name, database_name):
1445  self._oprot.writeMessageBegin('get_table_details_for_database', TMessageType.CALL, self._seqid)
1447  args.session = session
1448  args.table_name = table_name
1449  args.database_name = database_name
1450  args.write(self._oprot)
1451  self._oprot.writeMessageEnd()
1452  self._oprot.trans.flush()
1453 
1455  iprot = self._iprot
1456  (fname, mtype, rseqid) = iprot.readMessageBegin()
1457  if mtype == TMessageType.EXCEPTION:
1458  x = TApplicationException()
1459  x.read(iprot)
1460  iprot.readMessageEnd()
1461  raise x
1463  result.read(iprot)
1464  iprot.readMessageEnd()
1465  if result.success is not None:
1466  return result.success
1467  if result.e is not None:
1468  raise result.e
1469  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_details_for_database failed: unknown result")
1470 
1471  def get_internal_table_details(self, session, table_name):
1472  """
1473  Parameters:
1474  - session
1475  - table_name
1476 
1477  """
1478  self.send_get_internal_table_details(session, table_name)
1479  return self.recv_get_internal_table_details()
1480 
1481  def send_get_internal_table_details(self, session, table_name):
1482  self._oprot.writeMessageBegin('get_internal_table_details', TMessageType.CALL, self._seqid)
1484  args.session = session
1485  args.table_name = table_name
1486  args.write(self._oprot)
1487  self._oprot.writeMessageEnd()
1488  self._oprot.trans.flush()
1489 
1491  iprot = self._iprot
1492  (fname, mtype, rseqid) = iprot.readMessageBegin()
1493  if mtype == TMessageType.EXCEPTION:
1494  x = TApplicationException()
1495  x.read(iprot)
1496  iprot.readMessageEnd()
1497  raise x
1499  result.read(iprot)
1500  iprot.readMessageEnd()
1501  if result.success is not None:
1502  return result.success
1503  if result.e is not None:
1504  raise result.e
1505  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_internal_table_details failed: unknown result")
1506 
1507  def get_internal_table_details_for_database(self, session, table_name, database_name):
1508  """
1509  Parameters:
1510  - session
1511  - table_name
1512  - database_name
1513 
1514  """
1515  self.send_get_internal_table_details_for_database(session, table_name, database_name)
1517 
1518  def send_get_internal_table_details_for_database(self, session, table_name, database_name):
1519  self._oprot.writeMessageBegin('get_internal_table_details_for_database', TMessageType.CALL, self._seqid)
1521  args.session = session
1522  args.table_name = table_name
1523  args.database_name = database_name
1524  args.write(self._oprot)
1525  self._oprot.writeMessageEnd()
1526  self._oprot.trans.flush()
1527 
1529  iprot = self._iprot
1530  (fname, mtype, rseqid) = iprot.readMessageBegin()
1531  if mtype == TMessageType.EXCEPTION:
1532  x = TApplicationException()
1533  x.read(iprot)
1534  iprot.readMessageEnd()
1535  raise x
1537  result.read(iprot)
1538  iprot.readMessageEnd()
1539  if result.success is not None:
1540  return result.success
1541  if result.e is not None:
1542  raise result.e
1543  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_internal_table_details_for_database failed: unknown result")
1544 
1545  def get_users(self, session):
1546  """
1547  Parameters:
1548  - session
1549 
1550  """
1551  self.send_get_users(session)
1552  return self.recv_get_users()
1553 
1554  def send_get_users(self, session):
1555  self._oprot.writeMessageBegin('get_users', TMessageType.CALL, self._seqid)
1556  args = get_users_args()
1557  args.session = session
1558  args.write(self._oprot)
1559  self._oprot.writeMessageEnd()
1560  self._oprot.trans.flush()
1561 
1562  def recv_get_users(self):
1563  iprot = self._iprot
1564  (fname, mtype, rseqid) = iprot.readMessageBegin()
1565  if mtype == TMessageType.EXCEPTION:
1566  x = TApplicationException()
1567  x.read(iprot)
1568  iprot.readMessageEnd()
1569  raise x
1570  result = get_users_result()
1571  result.read(iprot)
1572  iprot.readMessageEnd()
1573  if result.success is not None:
1574  return result.success
1575  if result.e is not None:
1576  raise result.e
1577  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_users failed: unknown result")
1578 
1579  def get_databases(self, session):
1580  """
1581  Parameters:
1582  - session
1583 
1584  """
1585  self.send_get_databases(session)
1586  return self.recv_get_databases()
1587 
1588  def send_get_databases(self, session):
1589  self._oprot.writeMessageBegin('get_databases', TMessageType.CALL, self._seqid)
1590  args = get_databases_args()
1591  args.session = session
1592  args.write(self._oprot)
1593  self._oprot.writeMessageEnd()
1594  self._oprot.trans.flush()
1595 
1597  iprot = self._iprot
1598  (fname, mtype, rseqid) = iprot.readMessageBegin()
1599  if mtype == TMessageType.EXCEPTION:
1600  x = TApplicationException()
1601  x.read(iprot)
1602  iprot.readMessageEnd()
1603  raise x
1604  result = get_databases_result()
1605  result.read(iprot)
1606  iprot.readMessageEnd()
1607  if result.success is not None:
1608  return result.success
1609  if result.e is not None:
1610  raise result.e
1611  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_databases failed: unknown result")
1612 
1613  def get_version(self):
1614  self.send_get_version()
1615  return self.recv_get_version()
1616 
1617  def send_get_version(self):
1618  self._oprot.writeMessageBegin('get_version', TMessageType.CALL, self._seqid)
1619  args = get_version_args()
1620  args.write(self._oprot)
1621  self._oprot.writeMessageEnd()
1622  self._oprot.trans.flush()
1623 
1624  def recv_get_version(self):
1625  iprot = self._iprot
1626  (fname, mtype, rseqid) = iprot.readMessageBegin()
1627  if mtype == TMessageType.EXCEPTION:
1628  x = TApplicationException()
1629  x.read(iprot)
1630  iprot.readMessageEnd()
1631  raise x
1632  result = get_version_result()
1633  result.read(iprot)
1634  iprot.readMessageEnd()
1635  if result.success is not None:
1636  return result.success
1637  if result.e is not None:
1638  raise result.e
1639  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_version failed: unknown result")
1640 
1641  def start_heap_profile(self, session):
1642  """
1643  Parameters:
1644  - session
1645 
1646  """
1647  self.send_start_heap_profile(session)
1649 
1650  def send_start_heap_profile(self, session):
1651  self._oprot.writeMessageBegin('start_heap_profile', TMessageType.CALL, self._seqid)
1652  args = start_heap_profile_args()
1653  args.session = session
1654  args.write(self._oprot)
1655  self._oprot.writeMessageEnd()
1656  self._oprot.trans.flush()
1657 
1659  iprot = self._iprot
1660  (fname, mtype, rseqid) = iprot.readMessageBegin()
1661  if mtype == TMessageType.EXCEPTION:
1662  x = TApplicationException()
1663  x.read(iprot)
1664  iprot.readMessageEnd()
1665  raise x
1666  result = start_heap_profile_result()
1667  result.read(iprot)
1668  iprot.readMessageEnd()
1669  if result.e is not None:
1670  raise result.e
1671  return
1672 
1673  def stop_heap_profile(self, session):
1674  """
1675  Parameters:
1676  - session
1677 
1678  """
1679  self.send_stop_heap_profile(session)
1680  self.recv_stop_heap_profile()
1681 
1682  def send_stop_heap_profile(self, session):
1683  self._oprot.writeMessageBegin('stop_heap_profile', TMessageType.CALL, self._seqid)
1684  args = stop_heap_profile_args()
1685  args.session = session
1686  args.write(self._oprot)
1687  self._oprot.writeMessageEnd()
1688  self._oprot.trans.flush()
1689 
1691  iprot = self._iprot
1692  (fname, mtype, rseqid) = iprot.readMessageBegin()
1693  if mtype == TMessageType.EXCEPTION:
1694  x = TApplicationException()
1695  x.read(iprot)
1696  iprot.readMessageEnd()
1697  raise x
1698  result = stop_heap_profile_result()
1699  result.read(iprot)
1700  iprot.readMessageEnd()
1701  if result.e is not None:
1702  raise result.e
1703  return
1704 
1705  def get_heap_profile(self, session):
1706  """
1707  Parameters:
1708  - session
1709 
1710  """
1711  self.send_get_heap_profile(session)
1712  return self.recv_get_heap_profile()
1713 
1714  def send_get_heap_profile(self, session):
1715  self._oprot.writeMessageBegin('get_heap_profile', TMessageType.CALL, self._seqid)
1716  args = get_heap_profile_args()
1717  args.session = session
1718  args.write(self._oprot)
1719  self._oprot.writeMessageEnd()
1720  self._oprot.trans.flush()
1721 
1723  iprot = self._iprot
1724  (fname, mtype, rseqid) = iprot.readMessageBegin()
1725  if mtype == TMessageType.EXCEPTION:
1726  x = TApplicationException()
1727  x.read(iprot)
1728  iprot.readMessageEnd()
1729  raise x
1730  result = get_heap_profile_result()
1731  result.read(iprot)
1732  iprot.readMessageEnd()
1733  if result.success is not None:
1734  return result.success
1735  if result.e is not None:
1736  raise result.e
1737  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_heap_profile failed: unknown result")
1738 
1739  def get_memory(self, session, memory_level):
1740  """
1741  Parameters:
1742  - session
1743  - memory_level
1744 
1745  """
1746  self.send_get_memory(session, memory_level)
1747  return self.recv_get_memory()
1748 
1749  def send_get_memory(self, session, memory_level):
1750  self._oprot.writeMessageBegin('get_memory', TMessageType.CALL, self._seqid)
1751  args = get_memory_args()
1752  args.session = session
1753  args.memory_level = memory_level
1754  args.write(self._oprot)
1755  self._oprot.writeMessageEnd()
1756  self._oprot.trans.flush()
1757 
1758  def recv_get_memory(self):
1759  iprot = self._iprot
1760  (fname, mtype, rseqid) = iprot.readMessageBegin()
1761  if mtype == TMessageType.EXCEPTION:
1762  x = TApplicationException()
1763  x.read(iprot)
1764  iprot.readMessageEnd()
1765  raise x
1766  result = get_memory_result()
1767  result.read(iprot)
1768  iprot.readMessageEnd()
1769  if result.success is not None:
1770  return result.success
1771  if result.e is not None:
1772  raise result.e
1773  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_memory failed: unknown result")
1774 
1775  def clear_cpu_memory(self, session):
1776  """
1777  Parameters:
1778  - session
1779 
1780  """
1781  self.send_clear_cpu_memory(session)
1782  self.recv_clear_cpu_memory()
1783 
1784  def send_clear_cpu_memory(self, session):
1785  self._oprot.writeMessageBegin('clear_cpu_memory', TMessageType.CALL, self._seqid)
1786  args = clear_cpu_memory_args()
1787  args.session = session
1788  args.write(self._oprot)
1789  self._oprot.writeMessageEnd()
1790  self._oprot.trans.flush()
1791 
1793  iprot = self._iprot
1794  (fname, mtype, rseqid) = iprot.readMessageBegin()
1795  if mtype == TMessageType.EXCEPTION:
1796  x = TApplicationException()
1797  x.read(iprot)
1798  iprot.readMessageEnd()
1799  raise x
1800  result = clear_cpu_memory_result()
1801  result.read(iprot)
1802  iprot.readMessageEnd()
1803  if result.e is not None:
1804  raise result.e
1805  return
1806 
1807  def clear_gpu_memory(self, session):
1808  """
1809  Parameters:
1810  - session
1811 
1812  """
1813  self.send_clear_gpu_memory(session)
1814  self.recv_clear_gpu_memory()
1815 
1816  def send_clear_gpu_memory(self, session):
1817  self._oprot.writeMessageBegin('clear_gpu_memory', TMessageType.CALL, self._seqid)
1818  args = clear_gpu_memory_args()
1819  args.session = session
1820  args.write(self._oprot)
1821  self._oprot.writeMessageEnd()
1822  self._oprot.trans.flush()
1823 
1825  iprot = self._iprot
1826  (fname, mtype, rseqid) = iprot.readMessageBegin()
1827  if mtype == TMessageType.EXCEPTION:
1828  x = TApplicationException()
1829  x.read(iprot)
1830  iprot.readMessageEnd()
1831  raise x
1832  result = clear_gpu_memory_result()
1833  result.read(iprot)
1834  iprot.readMessageEnd()
1835  if result.e is not None:
1836  raise result.e
1837  return
1838 
1839  def set_cur_session(self, parent_session, leaf_session, start_time_str, label, for_running_query_kernel):
1840  """
1841  Parameters:
1842  - parent_session
1843  - leaf_session
1844  - start_time_str
1845  - label
1846  - for_running_query_kernel
1847 
1848  """
1849  self.send_set_cur_session(parent_session, leaf_session, start_time_str, label, for_running_query_kernel)
1850  self.recv_set_cur_session()
1851 
1852  def send_set_cur_session(self, parent_session, leaf_session, start_time_str, label, for_running_query_kernel):
1853  self._oprot.writeMessageBegin('set_cur_session', TMessageType.CALL, self._seqid)
1854  args = set_cur_session_args()
1855  args.parent_session = parent_session
1856  args.leaf_session = leaf_session
1857  args.start_time_str = start_time_str
1858  args.label = label
1859  args.for_running_query_kernel = for_running_query_kernel
1860  args.write(self._oprot)
1861  self._oprot.writeMessageEnd()
1862  self._oprot.trans.flush()
1863 
1865  iprot = self._iprot
1866  (fname, mtype, rseqid) = iprot.readMessageBegin()
1867  if mtype == TMessageType.EXCEPTION:
1868  x = TApplicationException()
1869  x.read(iprot)
1870  iprot.readMessageEnd()
1871  raise x
1872  result = set_cur_session_result()
1873  result.read(iprot)
1874  iprot.readMessageEnd()
1875  if result.e is not None:
1876  raise result.e
1877  return
1878 
1879  def invalidate_cur_session(self, parent_session, leaf_session, start_time_str, label, for_running_query_kernel):
1880  """
1881  Parameters:
1882  - parent_session
1883  - leaf_session
1884  - start_time_str
1885  - label
1886  - for_running_query_kernel
1887 
1888  """
1889  self.send_invalidate_cur_session(parent_session, leaf_session, start_time_str, label, for_running_query_kernel)
1891 
1892  def send_invalidate_cur_session(self, parent_session, leaf_session, start_time_str, label, for_running_query_kernel):
1893  self._oprot.writeMessageBegin('invalidate_cur_session', TMessageType.CALL, self._seqid)
1895  args.parent_session = parent_session
1896  args.leaf_session = leaf_session
1897  args.start_time_str = start_time_str
1898  args.label = label
1899  args.for_running_query_kernel = for_running_query_kernel
1900  args.write(self._oprot)
1901  self._oprot.writeMessageEnd()
1902  self._oprot.trans.flush()
1903 
1905  iprot = self._iprot
1906  (fname, mtype, rseqid) = iprot.readMessageBegin()
1907  if mtype == TMessageType.EXCEPTION:
1908  x = TApplicationException()
1909  x.read(iprot)
1910  iprot.readMessageEnd()
1911  raise x
1913  result.read(iprot)
1914  iprot.readMessageEnd()
1915  if result.e is not None:
1916  raise result.e
1917  return
1918 
1919  def set_table_epoch(self, session, db_id, table_id, new_epoch):
1920  """
1921  Parameters:
1922  - session
1923  - db_id
1924  - table_id
1925  - new_epoch
1926 
1927  """
1928  self.send_set_table_epoch(session, db_id, table_id, new_epoch)
1929  self.recv_set_table_epoch()
1930 
1931  def send_set_table_epoch(self, session, db_id, table_id, new_epoch):
1932  self._oprot.writeMessageBegin('set_table_epoch', TMessageType.CALL, self._seqid)
1933  args = set_table_epoch_args()
1934  args.session = session
1935  args.db_id = db_id
1936  args.table_id = table_id
1937  args.new_epoch = new_epoch
1938  args.write(self._oprot)
1939  self._oprot.writeMessageEnd()
1940  self._oprot.trans.flush()
1941 
1943  iprot = self._iprot
1944  (fname, mtype, rseqid) = iprot.readMessageBegin()
1945  if mtype == TMessageType.EXCEPTION:
1946  x = TApplicationException()
1947  x.read(iprot)
1948  iprot.readMessageEnd()
1949  raise x
1950  result = set_table_epoch_result()
1951  result.read(iprot)
1952  iprot.readMessageEnd()
1953  if result.e is not None:
1954  raise result.e
1955  return
1956 
1957  def set_table_epoch_by_name(self, session, table_name, new_epoch):
1958  """
1959  Parameters:
1960  - session
1961  - table_name
1962  - new_epoch
1963 
1964  """
1965  self.send_set_table_epoch_by_name(session, table_name, new_epoch)
1967 
1968  def send_set_table_epoch_by_name(self, session, table_name, new_epoch):
1969  self._oprot.writeMessageBegin('set_table_epoch_by_name', TMessageType.CALL, self._seqid)
1971  args.session = session
1972  args.table_name = table_name
1973  args.new_epoch = new_epoch
1974  args.write(self._oprot)
1975  self._oprot.writeMessageEnd()
1976  self._oprot.trans.flush()
1977 
1979  iprot = self._iprot
1980  (fname, mtype, rseqid) = iprot.readMessageBegin()
1981  if mtype == TMessageType.EXCEPTION:
1982  x = TApplicationException()
1983  x.read(iprot)
1984  iprot.readMessageEnd()
1985  raise x
1987  result.read(iprot)
1988  iprot.readMessageEnd()
1989  if result.e is not None:
1990  raise result.e
1991  return
1992 
1993  def get_table_epoch(self, session, db_id, table_id):
1994  """
1995  Parameters:
1996  - session
1997  - db_id
1998  - table_id
1999 
2000  """
2001  self.send_get_table_epoch(session, db_id, table_id)
2002  return self.recv_get_table_epoch()
2003 
2004  def send_get_table_epoch(self, session, db_id, table_id):
2005  self._oprot.writeMessageBegin('get_table_epoch', TMessageType.CALL, self._seqid)
2006  args = get_table_epoch_args()
2007  args.session = session
2008  args.db_id = db_id
2009  args.table_id = table_id
2010  args.write(self._oprot)
2011  self._oprot.writeMessageEnd()
2012  self._oprot.trans.flush()
2013 
2015  iprot = self._iprot
2016  (fname, mtype, rseqid) = iprot.readMessageBegin()
2017  if mtype == TMessageType.EXCEPTION:
2018  x = TApplicationException()
2019  x.read(iprot)
2020  iprot.readMessageEnd()
2021  raise x
2022  result = get_table_epoch_result()
2023  result.read(iprot)
2024  iprot.readMessageEnd()
2025  if result.success is not None:
2026  return result.success
2027  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_epoch failed: unknown result")
2028 
2029  def get_table_epoch_by_name(self, session, table_name):
2030  """
2031  Parameters:
2032  - session
2033  - table_name
2034 
2035  """
2036  self.send_get_table_epoch_by_name(session, table_name)
2037  return self.recv_get_table_epoch_by_name()
2038 
2039  def send_get_table_epoch_by_name(self, session, table_name):
2040  self._oprot.writeMessageBegin('get_table_epoch_by_name', TMessageType.CALL, self._seqid)
2042  args.session = session
2043  args.table_name = table_name
2044  args.write(self._oprot)
2045  self._oprot.writeMessageEnd()
2046  self._oprot.trans.flush()
2047 
2049  iprot = self._iprot
2050  (fname, mtype, rseqid) = iprot.readMessageBegin()
2051  if mtype == TMessageType.EXCEPTION:
2052  x = TApplicationException()
2053  x.read(iprot)
2054  iprot.readMessageEnd()
2055  raise x
2057  result.read(iprot)
2058  iprot.readMessageEnd()
2059  if result.success is not None:
2060  return result.success
2061  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_epoch_by_name failed: unknown result")
2062 
2063  def get_table_epochs(self, session, db_id, table_id):
2064  """
2065  Parameters:
2066  - session
2067  - db_id
2068  - table_id
2069 
2070  """
2071  self.send_get_table_epochs(session, db_id, table_id)
2072  return self.recv_get_table_epochs()
2073 
2074  def send_get_table_epochs(self, session, db_id, table_id):
2075  self._oprot.writeMessageBegin('get_table_epochs', TMessageType.CALL, self._seqid)
2076  args = get_table_epochs_args()
2077  args.session = session
2078  args.db_id = db_id
2079  args.table_id = table_id
2080  args.write(self._oprot)
2081  self._oprot.writeMessageEnd()
2082  self._oprot.trans.flush()
2083 
2085  iprot = self._iprot
2086  (fname, mtype, rseqid) = iprot.readMessageBegin()
2087  if mtype == TMessageType.EXCEPTION:
2088  x = TApplicationException()
2089  x.read(iprot)
2090  iprot.readMessageEnd()
2091  raise x
2092  result = get_table_epochs_result()
2093  result.read(iprot)
2094  iprot.readMessageEnd()
2095  if result.success is not None:
2096  return result.success
2097  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_epochs failed: unknown result")
2098 
2099  def set_table_epochs(self, session, db_id, table_epochs):
2100  """
2101  Parameters:
2102  - session
2103  - db_id
2104  - table_epochs
2105 
2106  """
2107  self.send_set_table_epochs(session, db_id, table_epochs)
2108  self.recv_set_table_epochs()
2109 
2110  def send_set_table_epochs(self, session, db_id, table_epochs):
2111  self._oprot.writeMessageBegin('set_table_epochs', TMessageType.CALL, self._seqid)
2112  args = set_table_epochs_args()
2113  args.session = session
2114  args.db_id = db_id
2115  args.table_epochs = table_epochs
2116  args.write(self._oprot)
2117  self._oprot.writeMessageEnd()
2118  self._oprot.trans.flush()
2119 
2121  iprot = self._iprot
2122  (fname, mtype, rseqid) = iprot.readMessageBegin()
2123  if mtype == TMessageType.EXCEPTION:
2124  x = TApplicationException()
2125  x.read(iprot)
2126  iprot.readMessageEnd()
2127  raise x
2128  result = set_table_epochs_result()
2129  result.read(iprot)
2130  iprot.readMessageEnd()
2131  return
2132 
2133  def get_session_info(self, session):
2134  """
2135  Parameters:
2136  - session
2137 
2138  """
2139  self.send_get_session_info(session)
2140  return self.recv_get_session_info()
2141 
2142  def send_get_session_info(self, session):
2143  self._oprot.writeMessageBegin('get_session_info', TMessageType.CALL, self._seqid)
2144  args = get_session_info_args()
2145  args.session = session
2146  args.write(self._oprot)
2147  self._oprot.writeMessageEnd()
2148  self._oprot.trans.flush()
2149 
2151  iprot = self._iprot
2152  (fname, mtype, rseqid) = iprot.readMessageBegin()
2153  if mtype == TMessageType.EXCEPTION:
2154  x = TApplicationException()
2155  x.read(iprot)
2156  iprot.readMessageEnd()
2157  raise x
2158  result = get_session_info_result()
2159  result.read(iprot)
2160  iprot.readMessageEnd()
2161  if result.success is not None:
2162  return result.success
2163  if result.e is not None:
2164  raise result.e
2165  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_session_info failed: unknown result")
2166 
2167  def sql_execute(self, session, query, column_format, nonce, first_n, at_most_n):
2168  """
2169  Parameters:
2170  - session
2171  - query
2172  - column_format
2173  - nonce
2174  - first_n
2175  - at_most_n
2176 
2177  """
2178  self.send_sql_execute(session, query, column_format, nonce, first_n, at_most_n)
2179  return self.recv_sql_execute()
2180 
2181  def send_sql_execute(self, session, query, column_format, nonce, first_n, at_most_n):
2182  self._oprot.writeMessageBegin('sql_execute', TMessageType.CALL, self._seqid)
2183  args = sql_execute_args()
2184  args.session = session
2185  args.query = query
2186  args.column_format = column_format
2187  args.nonce = nonce
2188  args.first_n = first_n
2189  args.at_most_n = at_most_n
2190  args.write(self._oprot)
2191  self._oprot.writeMessageEnd()
2192  self._oprot.trans.flush()
2193 
2194  def recv_sql_execute(self):
2195  iprot = self._iprot
2196  (fname, mtype, rseqid) = iprot.readMessageBegin()
2197  if mtype == TMessageType.EXCEPTION:
2198  x = TApplicationException()
2199  x.read(iprot)
2200  iprot.readMessageEnd()
2201  raise x
2202  result = sql_execute_result()
2203  result.read(iprot)
2204  iprot.readMessageEnd()
2205  if result.success is not None:
2206  return result.success
2207  if result.e is not None:
2208  raise result.e
2209  raise TApplicationException(TApplicationException.MISSING_RESULT, "sql_execute failed: unknown result")
2210 
2211  def sql_execute_df(self, session, query, device_type, device_id, first_n, transport_method):
2212  """
2213  Parameters:
2214  - session
2215  - query
2216  - device_type
2217  - device_id
2218  - first_n
2219  - transport_method
2220 
2221  """
2222  self.send_sql_execute_df(session, query, device_type, device_id, first_n, transport_method)
2223  return self.recv_sql_execute_df()
2224 
2225  def send_sql_execute_df(self, session, query, device_type, device_id, first_n, transport_method):
2226  self._oprot.writeMessageBegin('sql_execute_df', TMessageType.CALL, self._seqid)
2227  args = sql_execute_df_args()
2228  args.session = session
2229  args.query = query
2230  args.device_type = device_type
2231  args.device_id = device_id
2232  args.first_n = first_n
2233  args.transport_method = transport_method
2234  args.write(self._oprot)
2235  self._oprot.writeMessageEnd()
2236  self._oprot.trans.flush()
2237 
2239  iprot = self._iprot
2240  (fname, mtype, rseqid) = iprot.readMessageBegin()
2241  if mtype == TMessageType.EXCEPTION:
2242  x = TApplicationException()
2243  x.read(iprot)
2244  iprot.readMessageEnd()
2245  raise x
2246  result = sql_execute_df_result()
2247  result.read(iprot)
2248  iprot.readMessageEnd()
2249  if result.success is not None:
2250  return result.success
2251  if result.e is not None:
2252  raise result.e
2253  raise TApplicationException(TApplicationException.MISSING_RESULT, "sql_execute_df failed: unknown result")
2254 
2255  def sql_execute_gdf(self, session, query, device_id, first_n):
2256  """
2257  Parameters:
2258  - session
2259  - query
2260  - device_id
2261  - first_n
2262 
2263  """
2264  self.send_sql_execute_gdf(session, query, device_id, first_n)
2265  return self.recv_sql_execute_gdf()
2266 
2267  def send_sql_execute_gdf(self, session, query, device_id, first_n):
2268  self._oprot.writeMessageBegin('sql_execute_gdf', TMessageType.CALL, self._seqid)
2269  args = sql_execute_gdf_args()
2270  args.session = session
2271  args.query = query
2272  args.device_id = device_id
2273  args.first_n = first_n
2274  args.write(self._oprot)
2275  self._oprot.writeMessageEnd()
2276  self._oprot.trans.flush()
2277 
2279  iprot = self._iprot
2280  (fname, mtype, rseqid) = iprot.readMessageBegin()
2281  if mtype == TMessageType.EXCEPTION:
2282  x = TApplicationException()
2283  x.read(iprot)
2284  iprot.readMessageEnd()
2285  raise x
2286  result = sql_execute_gdf_result()
2287  result.read(iprot)
2288  iprot.readMessageEnd()
2289  if result.success is not None:
2290  return result.success
2291  if result.e is not None:
2292  raise result.e
2293  raise TApplicationException(TApplicationException.MISSING_RESULT, "sql_execute_gdf failed: unknown result")
2294 
2295  def deallocate_df(self, session, df, device_type, device_id):
2296  """
2297  Parameters:
2298  - session
2299  - df
2300  - device_type
2301  - device_id
2302 
2303  """
2304  self.send_deallocate_df(session, df, device_type, device_id)
2305  self.recv_deallocate_df()
2306 
2307  def send_deallocate_df(self, session, df, device_type, device_id):
2308  self._oprot.writeMessageBegin('deallocate_df', TMessageType.CALL, self._seqid)
2309  args = deallocate_df_args()
2310  args.session = session
2311  args.df = df
2312  args.device_type = device_type
2313  args.device_id = device_id
2314  args.write(self._oprot)
2315  self._oprot.writeMessageEnd()
2316  self._oprot.trans.flush()
2317 
2319  iprot = self._iprot
2320  (fname, mtype, rseqid) = iprot.readMessageBegin()
2321  if mtype == TMessageType.EXCEPTION:
2322  x = TApplicationException()
2323  x.read(iprot)
2324  iprot.readMessageEnd()
2325  raise x
2326  result = deallocate_df_result()
2327  result.read(iprot)
2328  iprot.readMessageEnd()
2329  if result.e is not None:
2330  raise result.e
2331  return
2332 
2333  def interrupt(self, query_session, interrupt_session):
2334  """
2335  Parameters:
2336  - query_session
2337  - interrupt_session
2338 
2339  """
2340  self.send_interrupt(query_session, interrupt_session)
2341  self.recv_interrupt()
2342 
2343  def send_interrupt(self, query_session, interrupt_session):
2344  self._oprot.writeMessageBegin('interrupt', TMessageType.CALL, self._seqid)
2345  args = interrupt_args()
2346  args.query_session = query_session
2347  args.interrupt_session = interrupt_session
2348  args.write(self._oprot)
2349  self._oprot.writeMessageEnd()
2350  self._oprot.trans.flush()
2351 
2352  def recv_interrupt(self):
2353  iprot = self._iprot
2354  (fname, mtype, rseqid) = iprot.readMessageBegin()
2355  if mtype == TMessageType.EXCEPTION:
2356  x = TApplicationException()
2357  x.read(iprot)
2358  iprot.readMessageEnd()
2359  raise x
2360  result = interrupt_result()
2361  result.read(iprot)
2362  iprot.readMessageEnd()
2363  if result.e is not None:
2364  raise result.e
2365  return
2366 
2367  def sql_validate(self, session, query):
2368  """
2369  Parameters:
2370  - session
2371  - query
2372 
2373  """
2374  self.send_sql_validate(session, query)
2375  return self.recv_sql_validate()
2376 
2377  def send_sql_validate(self, session, query):
2378  self._oprot.writeMessageBegin('sql_validate', TMessageType.CALL, self._seqid)
2379  args = sql_validate_args()
2380  args.session = session
2381  args.query = query
2382  args.write(self._oprot)
2383  self._oprot.writeMessageEnd()
2384  self._oprot.trans.flush()
2385 
2387  iprot = self._iprot
2388  (fname, mtype, rseqid) = iprot.readMessageBegin()
2389  if mtype == TMessageType.EXCEPTION:
2390  x = TApplicationException()
2391  x.read(iprot)
2392  iprot.readMessageEnd()
2393  raise x
2394  result = sql_validate_result()
2395  result.read(iprot)
2396  iprot.readMessageEnd()
2397  if result.success is not None:
2398  return result.success
2399  if result.e is not None:
2400  raise result.e
2401  raise TApplicationException(TApplicationException.MISSING_RESULT, "sql_validate failed: unknown result")
2402 
2403  def get_completion_hints(self, session, sql, cursor):
2404  """
2405  Parameters:
2406  - session
2407  - sql
2408  - cursor
2409 
2410  """
2411  self.send_get_completion_hints(session, sql, cursor)
2412  return self.recv_get_completion_hints()
2413 
2414  def send_get_completion_hints(self, session, sql, cursor):
2415  self._oprot.writeMessageBegin('get_completion_hints', TMessageType.CALL, self._seqid)
2416  args = get_completion_hints_args()
2417  args.session = session
2418  args.sql = sql
2419  args.cursor = cursor
2420  args.write(self._oprot)
2421  self._oprot.writeMessageEnd()
2422  self._oprot.trans.flush()
2423 
2425  iprot = self._iprot
2426  (fname, mtype, rseqid) = iprot.readMessageBegin()
2427  if mtype == TMessageType.EXCEPTION:
2428  x = TApplicationException()
2429  x.read(iprot)
2430  iprot.readMessageEnd()
2431  raise x
2432  result = get_completion_hints_result()
2433  result.read(iprot)
2434  iprot.readMessageEnd()
2435  if result.success is not None:
2436  return result.success
2437  if result.e is not None:
2438  raise result.e
2439  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_completion_hints failed: unknown result")
2440 
2441  def set_execution_mode(self, session, mode):
2442  """
2443  Parameters:
2444  - session
2445  - mode
2446 
2447  """
2448  self.send_set_execution_mode(session, mode)
2450 
2451  def send_set_execution_mode(self, session, mode):
2452  self._oprot.writeMessageBegin('set_execution_mode', TMessageType.CALL, self._seqid)
2453  args = set_execution_mode_args()
2454  args.session = session
2455  args.mode = mode
2456  args.write(self._oprot)
2457  self._oprot.writeMessageEnd()
2458  self._oprot.trans.flush()
2459 
2461  iprot = self._iprot
2462  (fname, mtype, rseqid) = iprot.readMessageBegin()
2463  if mtype == TMessageType.EXCEPTION:
2464  x = TApplicationException()
2465  x.read(iprot)
2466  iprot.readMessageEnd()
2467  raise x
2468  result = set_execution_mode_result()
2469  result.read(iprot)
2470  iprot.readMessageEnd()
2471  if result.e is not None:
2472  raise result.e
2473  return
2474 
2475  def render_vega(self, session, widget_id, vega_json, compression_level, nonce):
2476  """
2477  Parameters:
2478  - session
2479  - widget_id
2480  - vega_json
2481  - compression_level
2482  - nonce
2483 
2484  """
2485  self.send_render_vega(session, widget_id, vega_json, compression_level, nonce)
2486  return self.recv_render_vega()
2487 
2488  def send_render_vega(self, session, widget_id, vega_json, compression_level, nonce):
2489  self._oprot.writeMessageBegin('render_vega', TMessageType.CALL, self._seqid)
2490  args = render_vega_args()
2491  args.session = session
2492  args.widget_id = widget_id
2493  args.vega_json = vega_json
2494  args.compression_level = compression_level
2495  args.nonce = nonce
2496  args.write(self._oprot)
2497  self._oprot.writeMessageEnd()
2498  self._oprot.trans.flush()
2499 
2500  def recv_render_vega(self):
2501  iprot = self._iprot
2502  (fname, mtype, rseqid) = iprot.readMessageBegin()
2503  if mtype == TMessageType.EXCEPTION:
2504  x = TApplicationException()
2505  x.read(iprot)
2506  iprot.readMessageEnd()
2507  raise x
2508  result = render_vega_result()
2509  result.read(iprot)
2510  iprot.readMessageEnd()
2511  if result.success is not None:
2512  return result.success
2513  if result.e is not None:
2514  raise result.e
2515  raise TApplicationException(TApplicationException.MISSING_RESULT, "render_vega failed: unknown result")
2516 
2517  def get_result_row_for_pixel(self, session, widget_id, pixel, table_col_names, column_format, pixelRadius, nonce):
2518  """
2519  Parameters:
2520  - session
2521  - widget_id
2522  - pixel
2523  - table_col_names
2524  - column_format
2525  - pixelRadius
2526  - nonce
2527 
2528  """
2529  self.send_get_result_row_for_pixel(session, widget_id, pixel, table_col_names, column_format, pixelRadius, nonce)
2530  return self.recv_get_result_row_for_pixel()
2531 
2532  def send_get_result_row_for_pixel(self, session, widget_id, pixel, table_col_names, column_format, pixelRadius, nonce):
2533  self._oprot.writeMessageBegin('get_result_row_for_pixel', TMessageType.CALL, self._seqid)
2535  args.session = session
2536  args.widget_id = widget_id
2537  args.pixel = pixel
2538  args.table_col_names = table_col_names
2539  args.column_format = column_format
2540  args.pixelRadius = pixelRadius
2541  args.nonce = nonce
2542  args.write(self._oprot)
2543  self._oprot.writeMessageEnd()
2544  self._oprot.trans.flush()
2545 
2547  iprot = self._iprot
2548  (fname, mtype, rseqid) = iprot.readMessageBegin()
2549  if mtype == TMessageType.EXCEPTION:
2550  x = TApplicationException()
2551  x.read(iprot)
2552  iprot.readMessageEnd()
2553  raise x
2555  result.read(iprot)
2556  iprot.readMessageEnd()
2557  if result.success is not None:
2558  return result.success
2559  if result.e is not None:
2560  raise result.e
2561  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_result_row_for_pixel failed: unknown result")
2562 
2563  def create_custom_expression(self, session, custom_expression):
2564  """
2565  Parameters:
2566  - session
2567  - custom_expression
2568 
2569  """
2570  self.send_create_custom_expression(session, custom_expression)
2571  return self.recv_create_custom_expression()
2572 
2573  def send_create_custom_expression(self, session, custom_expression):
2574  self._oprot.writeMessageBegin('create_custom_expression', TMessageType.CALL, self._seqid)
2576  args.session = session
2577  args.custom_expression = custom_expression
2578  args.write(self._oprot)
2579  self._oprot.writeMessageEnd()
2580  self._oprot.trans.flush()
2581 
2583  iprot = self._iprot
2584  (fname, mtype, rseqid) = iprot.readMessageBegin()
2585  if mtype == TMessageType.EXCEPTION:
2586  x = TApplicationException()
2587  x.read(iprot)
2588  iprot.readMessageEnd()
2589  raise x
2591  result.read(iprot)
2592  iprot.readMessageEnd()
2593  if result.success is not None:
2594  return result.success
2595  if result.e is not None:
2596  raise result.e
2597  raise TApplicationException(TApplicationException.MISSING_RESULT, "create_custom_expression failed: unknown result")
2598 
2599  def get_custom_expressions(self, session):
2600  """
2601  Parameters:
2602  - session
2603 
2604  """
2605  self.send_get_custom_expressions(session)
2606  return self.recv_get_custom_expressions()
2607 
2608  def send_get_custom_expressions(self, session):
2609  self._oprot.writeMessageBegin('get_custom_expressions', TMessageType.CALL, self._seqid)
2611  args.session = session
2612  args.write(self._oprot)
2613  self._oprot.writeMessageEnd()
2614  self._oprot.trans.flush()
2615 
2617  iprot = self._iprot
2618  (fname, mtype, rseqid) = iprot.readMessageBegin()
2619  if mtype == TMessageType.EXCEPTION:
2620  x = TApplicationException()
2621  x.read(iprot)
2622  iprot.readMessageEnd()
2623  raise x
2625  result.read(iprot)
2626  iprot.readMessageEnd()
2627  if result.success is not None:
2628  return result.success
2629  if result.e is not None:
2630  raise result.e
2631  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_custom_expressions failed: unknown result")
2632 
2633  def update_custom_expression(self, session, id, expression_json):
2634  """
2635  Parameters:
2636  - session
2637  - id
2638  - expression_json
2639 
2640  """
2641  self.send_update_custom_expression(session, id, expression_json)
2643 
2644  def send_update_custom_expression(self, session, id, expression_json):
2645  self._oprot.writeMessageBegin('update_custom_expression', TMessageType.CALL, self._seqid)
2647  args.session = session
2648  args.id = id
2649  args.expression_json = expression_json
2650  args.write(self._oprot)
2651  self._oprot.writeMessageEnd()
2652  self._oprot.trans.flush()
2653 
2655  iprot = self._iprot
2656  (fname, mtype, rseqid) = iprot.readMessageBegin()
2657  if mtype == TMessageType.EXCEPTION:
2658  x = TApplicationException()
2659  x.read(iprot)
2660  iprot.readMessageEnd()
2661  raise x
2663  result.read(iprot)
2664  iprot.readMessageEnd()
2665  if result.e is not None:
2666  raise result.e
2667  return
2668 
2669  def delete_custom_expressions(self, session, custom_expression_ids, do_soft_delete):
2670  """
2671  Parameters:
2672  - session
2673  - custom_expression_ids
2674  - do_soft_delete
2675 
2676  """
2677  self.send_delete_custom_expressions(session, custom_expression_ids, do_soft_delete)
2679 
2680  def send_delete_custom_expressions(self, session, custom_expression_ids, do_soft_delete):
2681  self._oprot.writeMessageBegin('delete_custom_expressions', TMessageType.CALL, self._seqid)
2683  args.session = session
2684  args.custom_expression_ids = custom_expression_ids
2685  args.do_soft_delete = do_soft_delete
2686  args.write(self._oprot)
2687  self._oprot.writeMessageEnd()
2688  self._oprot.trans.flush()
2689 
2691  iprot = self._iprot
2692  (fname, mtype, rseqid) = iprot.readMessageBegin()
2693  if mtype == TMessageType.EXCEPTION:
2694  x = TApplicationException()
2695  x.read(iprot)
2696  iprot.readMessageEnd()
2697  raise x
2699  result.read(iprot)
2700  iprot.readMessageEnd()
2701  if result.e is not None:
2702  raise result.e
2703  return
2704 
2705  def get_dashboard(self, session, dashboard_id):
2706  """
2707  Parameters:
2708  - session
2709  - dashboard_id
2710 
2711  """
2712  self.send_get_dashboard(session, dashboard_id)
2713  return self.recv_get_dashboard()
2714 
2715  def send_get_dashboard(self, session, dashboard_id):
2716  self._oprot.writeMessageBegin('get_dashboard', TMessageType.CALL, self._seqid)
2717  args = get_dashboard_args()
2718  args.session = session
2719  args.dashboard_id = dashboard_id
2720  args.write(self._oprot)
2721  self._oprot.writeMessageEnd()
2722  self._oprot.trans.flush()
2723 
2725  iprot = self._iprot
2726  (fname, mtype, rseqid) = iprot.readMessageBegin()
2727  if mtype == TMessageType.EXCEPTION:
2728  x = TApplicationException()
2729  x.read(iprot)
2730  iprot.readMessageEnd()
2731  raise x
2732  result = get_dashboard_result()
2733  result.read(iprot)
2734  iprot.readMessageEnd()
2735  if result.success is not None:
2736  return result.success
2737  if result.e is not None:
2738  raise result.e
2739  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_dashboard failed: unknown result")
2740 
2741  def get_dashboards(self, session):
2742  """
2743  Parameters:
2744  - session
2745 
2746  """
2747  self.send_get_dashboards(session)
2748  return self.recv_get_dashboards()
2749 
2750  def send_get_dashboards(self, session):
2751  self._oprot.writeMessageBegin('get_dashboards', TMessageType.CALL, self._seqid)
2752  args = get_dashboards_args()
2753  args.session = session
2754  args.write(self._oprot)
2755  self._oprot.writeMessageEnd()
2756  self._oprot.trans.flush()
2757 
2759  iprot = self._iprot
2760  (fname, mtype, rseqid) = iprot.readMessageBegin()
2761  if mtype == TMessageType.EXCEPTION:
2762  x = TApplicationException()
2763  x.read(iprot)
2764  iprot.readMessageEnd()
2765  raise x
2766  result = get_dashboards_result()
2767  result.read(iprot)
2768  iprot.readMessageEnd()
2769  if result.success is not None:
2770  return result.success
2771  if result.e is not None:
2772  raise result.e
2773  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_dashboards failed: unknown result")
2774 
2775  def create_dashboard(self, session, dashboard_name, dashboard_state, image_hash, dashboard_metadata):
2776  """
2777  Parameters:
2778  - session
2779  - dashboard_name
2780  - dashboard_state
2781  - image_hash
2782  - dashboard_metadata
2783 
2784  """
2785  self.send_create_dashboard(session, dashboard_name, dashboard_state, image_hash, dashboard_metadata)
2786  return self.recv_create_dashboard()
2787 
2788  def send_create_dashboard(self, session, dashboard_name, dashboard_state, image_hash, dashboard_metadata):
2789  self._oprot.writeMessageBegin('create_dashboard', TMessageType.CALL, self._seqid)
2790  args = create_dashboard_args()
2791  args.session = session
2792  args.dashboard_name = dashboard_name
2793  args.dashboard_state = dashboard_state
2794  args.image_hash = image_hash
2795  args.dashboard_metadata = dashboard_metadata
2796  args.write(self._oprot)
2797  self._oprot.writeMessageEnd()
2798  self._oprot.trans.flush()
2799 
2801  iprot = self._iprot
2802  (fname, mtype, rseqid) = iprot.readMessageBegin()
2803  if mtype == TMessageType.EXCEPTION:
2804  x = TApplicationException()
2805  x.read(iprot)
2806  iprot.readMessageEnd()
2807  raise x
2808  result = create_dashboard_result()
2809  result.read(iprot)
2810  iprot.readMessageEnd()
2811  if result.success is not None:
2812  return result.success
2813  if result.e is not None:
2814  raise result.e
2815  raise TApplicationException(TApplicationException.MISSING_RESULT, "create_dashboard failed: unknown result")
2816 
2817  def replace_dashboard(self, session, dashboard_id, dashboard_name, dashboard_owner, dashboard_state, image_hash, dashboard_metadata):
2818  """
2819  Parameters:
2820  - session
2821  - dashboard_id
2822  - dashboard_name
2823  - dashboard_owner
2824  - dashboard_state
2825  - image_hash
2826  - dashboard_metadata
2827 
2828  """
2829  self.send_replace_dashboard(session, dashboard_id, dashboard_name, dashboard_owner, dashboard_state, image_hash, dashboard_metadata)
2830  self.recv_replace_dashboard()
2831 
2832  def send_replace_dashboard(self, session, dashboard_id, dashboard_name, dashboard_owner, dashboard_state, image_hash, dashboard_metadata):
2833  self._oprot.writeMessageBegin('replace_dashboard', TMessageType.CALL, self._seqid)
2834  args = replace_dashboard_args()
2835  args.session = session
2836  args.dashboard_id = dashboard_id
2837  args.dashboard_name = dashboard_name
2838  args.dashboard_owner = dashboard_owner
2839  args.dashboard_state = dashboard_state
2840  args.image_hash = image_hash
2841  args.dashboard_metadata = dashboard_metadata
2842  args.write(self._oprot)
2843  self._oprot.writeMessageEnd()
2844  self._oprot.trans.flush()
2845 
2847  iprot = self._iprot
2848  (fname, mtype, rseqid) = iprot.readMessageBegin()
2849  if mtype == TMessageType.EXCEPTION:
2850  x = TApplicationException()
2851  x.read(iprot)
2852  iprot.readMessageEnd()
2853  raise x
2854  result = replace_dashboard_result()
2855  result.read(iprot)
2856  iprot.readMessageEnd()
2857  if result.e is not None:
2858  raise result.e
2859  return
2860 
2861  def delete_dashboard(self, session, dashboard_id):
2862  """
2863  Parameters:
2864  - session
2865  - dashboard_id
2866 
2867  """
2868  self.send_delete_dashboard(session, dashboard_id)
2869  self.recv_delete_dashboard()
2870 
2871  def send_delete_dashboard(self, session, dashboard_id):
2872  self._oprot.writeMessageBegin('delete_dashboard', TMessageType.CALL, self._seqid)
2873  args = delete_dashboard_args()
2874  args.session = session
2875  args.dashboard_id = dashboard_id
2876  args.write(self._oprot)
2877  self._oprot.writeMessageEnd()
2878  self._oprot.trans.flush()
2879 
2881  iprot = self._iprot
2882  (fname, mtype, rseqid) = iprot.readMessageBegin()
2883  if mtype == TMessageType.EXCEPTION:
2884  x = TApplicationException()
2885  x.read(iprot)
2886  iprot.readMessageEnd()
2887  raise x
2888  result = delete_dashboard_result()
2889  result.read(iprot)
2890  iprot.readMessageEnd()
2891  if result.e is not None:
2892  raise result.e
2893  return
2894 
2895  def share_dashboards(self, session, dashboard_ids, groups, permissions):
2896  """
2897  Parameters:
2898  - session
2899  - dashboard_ids
2900  - groups
2901  - permissions
2902 
2903  """
2904  self.send_share_dashboards(session, dashboard_ids, groups, permissions)
2905  self.recv_share_dashboards()
2906 
2907  def send_share_dashboards(self, session, dashboard_ids, groups, permissions):
2908  self._oprot.writeMessageBegin('share_dashboards', TMessageType.CALL, self._seqid)
2909  args = share_dashboards_args()
2910  args.session = session
2911  args.dashboard_ids = dashboard_ids
2912  args.groups = groups
2913  args.permissions = permissions
2914  args.write(self._oprot)
2915  self._oprot.writeMessageEnd()
2916  self._oprot.trans.flush()
2917 
2919  iprot = self._iprot
2920  (fname, mtype, rseqid) = iprot.readMessageBegin()
2921  if mtype == TMessageType.EXCEPTION:
2922  x = TApplicationException()
2923  x.read(iprot)
2924  iprot.readMessageEnd()
2925  raise x
2926  result = share_dashboards_result()
2927  result.read(iprot)
2928  iprot.readMessageEnd()
2929  if result.e is not None:
2930  raise result.e
2931  return
2932 
2933  def delete_dashboards(self, session, dashboard_ids):
2934  """
2935  Parameters:
2936  - session
2937  - dashboard_ids
2938 
2939  """
2940  self.send_delete_dashboards(session, dashboard_ids)
2941  self.recv_delete_dashboards()
2942 
2943  def send_delete_dashboards(self, session, dashboard_ids):
2944  self._oprot.writeMessageBegin('delete_dashboards', TMessageType.CALL, self._seqid)
2945  args = delete_dashboards_args()
2946  args.session = session
2947  args.dashboard_ids = dashboard_ids
2948  args.write(self._oprot)
2949  self._oprot.writeMessageEnd()
2950  self._oprot.trans.flush()
2951 
2953  iprot = self._iprot
2954  (fname, mtype, rseqid) = iprot.readMessageBegin()
2955  if mtype == TMessageType.EXCEPTION:
2956  x = TApplicationException()
2957  x.read(iprot)
2958  iprot.readMessageEnd()
2959  raise x
2960  result = delete_dashboards_result()
2961  result.read(iprot)
2962  iprot.readMessageEnd()
2963  if result.e is not None:
2964  raise result.e
2965  return
2966 
2967  def share_dashboard(self, session, dashboard_id, groups, objects, permissions, grant_role):
2968  """
2969  Parameters:
2970  - session
2971  - dashboard_id
2972  - groups
2973  - objects
2974  - permissions
2975  - grant_role
2976 
2977  """
2978  self.send_share_dashboard(session, dashboard_id, groups, objects, permissions, grant_role)
2979  self.recv_share_dashboard()
2980 
2981  def send_share_dashboard(self, session, dashboard_id, groups, objects, permissions, grant_role):
2982  self._oprot.writeMessageBegin('share_dashboard', TMessageType.CALL, self._seqid)
2983  args = share_dashboard_args()
2984  args.session = session
2985  args.dashboard_id = dashboard_id
2986  args.groups = groups
2987  args.objects = objects
2988  args.permissions = permissions
2989  args.grant_role = grant_role
2990  args.write(self._oprot)
2991  self._oprot.writeMessageEnd()
2992  self._oprot.trans.flush()
2993 
2995  iprot = self._iprot
2996  (fname, mtype, rseqid) = iprot.readMessageBegin()
2997  if mtype == TMessageType.EXCEPTION:
2998  x = TApplicationException()
2999  x.read(iprot)
3000  iprot.readMessageEnd()
3001  raise x
3002  result = share_dashboard_result()
3003  result.read(iprot)
3004  iprot.readMessageEnd()
3005  if result.e is not None:
3006  raise result.e
3007  return
3008 
3009  def unshare_dashboard(self, session, dashboard_id, groups, objects, permissions):
3010  """
3011  Parameters:
3012  - session
3013  - dashboard_id
3014  - groups
3015  - objects
3016  - permissions
3017 
3018  """
3019  self.send_unshare_dashboard(session, dashboard_id, groups, objects, permissions)
3020  self.recv_unshare_dashboard()
3021 
3022  def send_unshare_dashboard(self, session, dashboard_id, groups, objects, permissions):
3023  self._oprot.writeMessageBegin('unshare_dashboard', TMessageType.CALL, self._seqid)
3024  args = unshare_dashboard_args()
3025  args.session = session
3026  args.dashboard_id = dashboard_id
3027  args.groups = groups
3028  args.objects = objects
3029  args.permissions = permissions
3030  args.write(self._oprot)
3031  self._oprot.writeMessageEnd()
3032  self._oprot.trans.flush()
3033 
3035  iprot = self._iprot
3036  (fname, mtype, rseqid) = iprot.readMessageBegin()
3037  if mtype == TMessageType.EXCEPTION:
3038  x = TApplicationException()
3039  x.read(iprot)
3040  iprot.readMessageEnd()
3041  raise x
3042  result = unshare_dashboard_result()
3043  result.read(iprot)
3044  iprot.readMessageEnd()
3045  if result.e is not None:
3046  raise result.e
3047  return
3048 
3049  def unshare_dashboards(self, session, dashboard_ids, groups, permissions):
3050  """
3051  Parameters:
3052  - session
3053  - dashboard_ids
3054  - groups
3055  - permissions
3056 
3057  """
3058  self.send_unshare_dashboards(session, dashboard_ids, groups, permissions)
3060 
3061  def send_unshare_dashboards(self, session, dashboard_ids, groups, permissions):
3062  self._oprot.writeMessageBegin('unshare_dashboards', TMessageType.CALL, self._seqid)
3063  args = unshare_dashboards_args()
3064  args.session = session
3065  args.dashboard_ids = dashboard_ids
3066  args.groups = groups
3067  args.permissions = permissions
3068  args.write(self._oprot)
3069  self._oprot.writeMessageEnd()
3070  self._oprot.trans.flush()
3071 
3073  iprot = self._iprot
3074  (fname, mtype, rseqid) = iprot.readMessageBegin()
3075  if mtype == TMessageType.EXCEPTION:
3076  x = TApplicationException()
3077  x.read(iprot)
3078  iprot.readMessageEnd()
3079  raise x
3080  result = unshare_dashboards_result()
3081  result.read(iprot)
3082  iprot.readMessageEnd()
3083  if result.e is not None:
3084  raise result.e
3085  return
3086 
3087  def get_dashboard_grantees(self, session, dashboard_id):
3088  """
3089  Parameters:
3090  - session
3091  - dashboard_id
3092 
3093  """
3094  self.send_get_dashboard_grantees(session, dashboard_id)
3095  return self.recv_get_dashboard_grantees()
3096 
3097  def send_get_dashboard_grantees(self, session, dashboard_id):
3098  self._oprot.writeMessageBegin('get_dashboard_grantees', TMessageType.CALL, self._seqid)
3100  args.session = session
3101  args.dashboard_id = dashboard_id
3102  args.write(self._oprot)
3103  self._oprot.writeMessageEnd()
3104  self._oprot.trans.flush()
3105 
3107  iprot = self._iprot
3108  (fname, mtype, rseqid) = iprot.readMessageBegin()
3109  if mtype == TMessageType.EXCEPTION:
3110  x = TApplicationException()
3111  x.read(iprot)
3112  iprot.readMessageEnd()
3113  raise x
3115  result.read(iprot)
3116  iprot.readMessageEnd()
3117  if result.success is not None:
3118  return result.success
3119  if result.e is not None:
3120  raise result.e
3121  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_dashboard_grantees failed: unknown result")
3122 
3123  def get_link_view(self, session, link):
3124  """
3125  Parameters:
3126  - session
3127  - link
3128 
3129  """
3130  self.send_get_link_view(session, link)
3131  return self.recv_get_link_view()
3132 
3133  def send_get_link_view(self, session, link):
3134  self._oprot.writeMessageBegin('get_link_view', TMessageType.CALL, self._seqid)
3135  args = get_link_view_args()
3136  args.session = session
3137  args.link = link
3138  args.write(self._oprot)
3139  self._oprot.writeMessageEnd()
3140  self._oprot.trans.flush()
3141 
3143  iprot = self._iprot
3144  (fname, mtype, rseqid) = iprot.readMessageBegin()
3145  if mtype == TMessageType.EXCEPTION:
3146  x = TApplicationException()
3147  x.read(iprot)
3148  iprot.readMessageEnd()
3149  raise x
3150  result = get_link_view_result()
3151  result.read(iprot)
3152  iprot.readMessageEnd()
3153  if result.success is not None:
3154  return result.success
3155  if result.e is not None:
3156  raise result.e
3157  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_link_view failed: unknown result")
3158 
3159  def create_link(self, session, view_state, view_metadata):
3160  """
3161  Parameters:
3162  - session
3163  - view_state
3164  - view_metadata
3165 
3166  """
3167  self.send_create_link(session, view_state, view_metadata)
3168  return self.recv_create_link()
3169 
3170  def send_create_link(self, session, view_state, view_metadata):
3171  self._oprot.writeMessageBegin('create_link', TMessageType.CALL, self._seqid)
3172  args = create_link_args()
3173  args.session = session
3174  args.view_state = view_state
3175  args.view_metadata = view_metadata
3176  args.write(self._oprot)
3177  self._oprot.writeMessageEnd()
3178  self._oprot.trans.flush()
3179 
3180  def recv_create_link(self):
3181  iprot = self._iprot
3182  (fname, mtype, rseqid) = iprot.readMessageBegin()
3183  if mtype == TMessageType.EXCEPTION:
3184  x = TApplicationException()
3185  x.read(iprot)
3186  iprot.readMessageEnd()
3187  raise x
3188  result = create_link_result()
3189  result.read(iprot)
3190  iprot.readMessageEnd()
3191  if result.success is not None:
3192  return result.success
3193  if result.e is not None:
3194  raise result.e
3195  raise TApplicationException(TApplicationException.MISSING_RESULT, "create_link failed: unknown result")
3196 
3197  def load_table_binary(self, session, table_name, rows, column_names):
3198  """
3199  Parameters:
3200  - session
3201  - table_name
3202  - rows
3203  - column_names
3204 
3205  """
3206  self.send_load_table_binary(session, table_name, rows, column_names)
3207  self.recv_load_table_binary()
3208 
3209  def send_load_table_binary(self, session, table_name, rows, column_names):
3210  self._oprot.writeMessageBegin('load_table_binary', TMessageType.CALL, self._seqid)
3211  args = load_table_binary_args()
3212  args.session = session
3213  args.table_name = table_name
3214  args.rows = rows
3215  args.column_names = column_names
3216  args.write(self._oprot)
3217  self._oprot.writeMessageEnd()
3218  self._oprot.trans.flush()
3219 
3221  iprot = self._iprot
3222  (fname, mtype, rseqid) = iprot.readMessageBegin()
3223  if mtype == TMessageType.EXCEPTION:
3224  x = TApplicationException()
3225  x.read(iprot)
3226  iprot.readMessageEnd()
3227  raise x
3228  result = load_table_binary_result()
3229  result.read(iprot)
3230  iprot.readMessageEnd()
3231  if result.e is not None:
3232  raise result.e
3233  return
3234 
3235  def load_table_binary_columnar(self, session, table_name, cols, column_names):
3236  """
3237  Parameters:
3238  - session
3239  - table_name
3240  - cols
3241  - column_names
3242 
3243  """
3244  self.send_load_table_binary_columnar(session, table_name, cols, column_names)
3246 
3247  def send_load_table_binary_columnar(self, session, table_name, cols, column_names):
3248  self._oprot.writeMessageBegin('load_table_binary_columnar', TMessageType.CALL, self._seqid)
3250  args.session = session
3251  args.table_name = table_name
3252  args.cols = cols
3253  args.column_names = column_names
3254  args.write(self._oprot)
3255  self._oprot.writeMessageEnd()
3256  self._oprot.trans.flush()
3257 
3259  iprot = self._iprot
3260  (fname, mtype, rseqid) = iprot.readMessageBegin()
3261  if mtype == TMessageType.EXCEPTION:
3262  x = TApplicationException()
3263  x.read(iprot)
3264  iprot.readMessageEnd()
3265  raise x
3267  result.read(iprot)
3268  iprot.readMessageEnd()
3269  if result.e is not None:
3270  raise result.e
3271  return
3272 
3273  def load_table_binary_columnar_polys(self, session, table_name, cols, column_names, assign_render_groups):
3274  """
3275  Parameters:
3276  - session
3277  - table_name
3278  - cols
3279  - column_names
3280  - assign_render_groups
3281 
3282  """
3283  self.send_load_table_binary_columnar_polys(session, table_name, cols, column_names, assign_render_groups)
3285 
3286  def send_load_table_binary_columnar_polys(self, session, table_name, cols, column_names, assign_render_groups):
3287  self._oprot.writeMessageBegin('load_table_binary_columnar_polys', TMessageType.CALL, self._seqid)
3289  args.session = session
3290  args.table_name = table_name
3291  args.cols = cols
3292  args.column_names = column_names
3293  args.assign_render_groups = assign_render_groups
3294  args.write(self._oprot)
3295  self._oprot.writeMessageEnd()
3296  self._oprot.trans.flush()
3297 
3299  iprot = self._iprot
3300  (fname, mtype, rseqid) = iprot.readMessageBegin()
3301  if mtype == TMessageType.EXCEPTION:
3302  x = TApplicationException()
3303  x.read(iprot)
3304  iprot.readMessageEnd()
3305  raise x
3307  result.read(iprot)
3308  iprot.readMessageEnd()
3309  if result.e is not None:
3310  raise result.e
3311  return
3312 
3313  def load_table_binary_arrow(self, session, table_name, arrow_stream, use_column_names):
3314  """
3315  Parameters:
3316  - session
3317  - table_name
3318  - arrow_stream
3319  - use_column_names
3320 
3321  """
3322  self.send_load_table_binary_arrow(session, table_name, arrow_stream, use_column_names)
3324 
3325  def send_load_table_binary_arrow(self, session, table_name, arrow_stream, use_column_names):
3326  self._oprot.writeMessageBegin('load_table_binary_arrow', TMessageType.CALL, self._seqid)
3328  args.session = session
3329  args.table_name = table_name
3330  args.arrow_stream = arrow_stream
3331  args.use_column_names = use_column_names
3332  args.write(self._oprot)
3333  self._oprot.writeMessageEnd()
3334  self._oprot.trans.flush()
3335 
3337  iprot = self._iprot
3338  (fname, mtype, rseqid) = iprot.readMessageBegin()
3339  if mtype == TMessageType.EXCEPTION:
3340  x = TApplicationException()
3341  x.read(iprot)
3342  iprot.readMessageEnd()
3343  raise x
3345  result.read(iprot)
3346  iprot.readMessageEnd()
3347  if result.e is not None:
3348  raise result.e
3349  return
3350 
3351  def load_table(self, session, table_name, rows, column_names):
3352  """
3353  Parameters:
3354  - session
3355  - table_name
3356  - rows
3357  - column_names
3358 
3359  """
3360  self.send_load_table(session, table_name, rows, column_names)
3361  self.recv_load_table()
3362 
3363  def send_load_table(self, session, table_name, rows, column_names):
3364  self._oprot.writeMessageBegin('load_table', TMessageType.CALL, self._seqid)
3365  args = load_table_args()
3366  args.session = session
3367  args.table_name = table_name
3368  args.rows = rows
3369  args.column_names = column_names
3370  args.write(self._oprot)
3371  self._oprot.writeMessageEnd()
3372  self._oprot.trans.flush()
3373 
3374  def recv_load_table(self):
3375  iprot = self._iprot
3376  (fname, mtype, rseqid) = iprot.readMessageBegin()
3377  if mtype == TMessageType.EXCEPTION:
3378  x = TApplicationException()
3379  x.read(iprot)
3380  iprot.readMessageEnd()
3381  raise x
3382  result = load_table_result()
3383  result.read(iprot)
3384  iprot.readMessageEnd()
3385  if result.e is not None:
3386  raise result.e
3387  return
3388 
3389  def detect_column_types(self, session, file_name, copy_params):
3390  """
3391  Parameters:
3392  - session
3393  - file_name
3394  - copy_params
3395 
3396  """
3397  self.send_detect_column_types(session, file_name, copy_params)
3398  return self.recv_detect_column_types()
3399 
3400  def send_detect_column_types(self, session, file_name, copy_params):
3401  self._oprot.writeMessageBegin('detect_column_types', TMessageType.CALL, self._seqid)
3402  args = detect_column_types_args()
3403  args.session = session
3404  args.file_name = file_name
3405  args.copy_params = copy_params
3406  args.write(self._oprot)
3407  self._oprot.writeMessageEnd()
3408  self._oprot.trans.flush()
3409 
3411  iprot = self._iprot
3412  (fname, mtype, rseqid) = iprot.readMessageBegin()
3413  if mtype == TMessageType.EXCEPTION:
3414  x = TApplicationException()
3415  x.read(iprot)
3416  iprot.readMessageEnd()
3417  raise x
3418  result = detect_column_types_result()
3419  result.read(iprot)
3420  iprot.readMessageEnd()
3421  if result.success is not None:
3422  return result.success
3423  if result.e is not None:
3424  raise result.e
3425  raise TApplicationException(TApplicationException.MISSING_RESULT, "detect_column_types failed: unknown result")
3426 
3427  def create_table(self, session, table_name, row_desc, file_type, create_params):
3428  """
3429  Parameters:
3430  - session
3431  - table_name
3432  - row_desc
3433  - file_type
3434  - create_params
3435 
3436  """
3437  self.send_create_table(session, table_name, row_desc, file_type, create_params)
3438  self.recv_create_table()
3439 
3440  def send_create_table(self, session, table_name, row_desc, file_type, create_params):
3441  self._oprot.writeMessageBegin('create_table', TMessageType.CALL, self._seqid)
3442  args = create_table_args()
3443  args.session = session
3444  args.table_name = table_name
3445  args.row_desc = row_desc
3446  args.file_type = file_type
3447  args.create_params = create_params
3448  args.write(self._oprot)
3449  self._oprot.writeMessageEnd()
3450  self._oprot.trans.flush()
3451 
3453  iprot = self._iprot
3454  (fname, mtype, rseqid) = iprot.readMessageBegin()
3455  if mtype == TMessageType.EXCEPTION:
3456  x = TApplicationException()
3457  x.read(iprot)
3458  iprot.readMessageEnd()
3459  raise x
3460  result = create_table_result()
3461  result.read(iprot)
3462  iprot.readMessageEnd()
3463  if result.e is not None:
3464  raise result.e
3465  return
3466 
3467  def import_table(self, session, table_name, file_name, copy_params):
3468  """
3469  Parameters:
3470  - session
3471  - table_name
3472  - file_name
3473  - copy_params
3474 
3475  """
3476  self.send_import_table(session, table_name, file_name, copy_params)
3477  self.recv_import_table()
3478 
3479  def send_import_table(self, session, table_name, file_name, copy_params):
3480  self._oprot.writeMessageBegin('import_table', TMessageType.CALL, self._seqid)
3481  args = import_table_args()
3482  args.session = session
3483  args.table_name = table_name
3484  args.file_name = file_name
3485  args.copy_params = copy_params
3486  args.write(self._oprot)
3487  self._oprot.writeMessageEnd()
3488  self._oprot.trans.flush()
3489 
3491  iprot = self._iprot
3492  (fname, mtype, rseqid) = iprot.readMessageBegin()
3493  if mtype == TMessageType.EXCEPTION:
3494  x = TApplicationException()
3495  x.read(iprot)
3496  iprot.readMessageEnd()
3497  raise x
3498  result = import_table_result()
3499  result.read(iprot)
3500  iprot.readMessageEnd()
3501  if result.e is not None:
3502  raise result.e
3503  return
3504 
3505  def import_geo_table(self, session, table_name, file_name, copy_params, row_desc, create_params):
3506  """
3507  Parameters:
3508  - session
3509  - table_name
3510  - file_name
3511  - copy_params
3512  - row_desc
3513  - create_params
3514 
3515  """
3516  self.send_import_geo_table(session, table_name, file_name, copy_params, row_desc, create_params)
3517  self.recv_import_geo_table()
3518 
3519  def send_import_geo_table(self, session, table_name, file_name, copy_params, row_desc, create_params):
3520  self._oprot.writeMessageBegin('import_geo_table', TMessageType.CALL, self._seqid)
3521  args = import_geo_table_args()
3522  args.session = session
3523  args.table_name = table_name
3524  args.file_name = file_name
3525  args.copy_params = copy_params
3526  args.row_desc = row_desc
3527  args.create_params = create_params
3528  args.write(self._oprot)
3529  self._oprot.writeMessageEnd()
3530  self._oprot.trans.flush()
3531 
3533  iprot = self._iprot
3534  (fname, mtype, rseqid) = iprot.readMessageBegin()
3535  if mtype == TMessageType.EXCEPTION:
3536  x = TApplicationException()
3537  x.read(iprot)
3538  iprot.readMessageEnd()
3539  raise x
3540  result = import_geo_table_result()
3541  result.read(iprot)
3542  iprot.readMessageEnd()
3543  if result.e is not None:
3544  raise result.e
3545  return
3546 
3547  def import_table_status(self, session, import_id):
3548  """
3549  Parameters:
3550  - session
3551  - import_id
3552 
3553  """
3554  self.send_import_table_status(session, import_id)
3555  return self.recv_import_table_status()
3556 
3557  def send_import_table_status(self, session, import_id):
3558  self._oprot.writeMessageBegin('import_table_status', TMessageType.CALL, self._seqid)
3559  args = import_table_status_args()
3560  args.session = session
3561  args.import_id = import_id
3562  args.write(self._oprot)
3563  self._oprot.writeMessageEnd()
3564  self._oprot.trans.flush()
3565 
3567  iprot = self._iprot
3568  (fname, mtype, rseqid) = iprot.readMessageBegin()
3569  if mtype == TMessageType.EXCEPTION:
3570  x = TApplicationException()
3571  x.read(iprot)
3572  iprot.readMessageEnd()
3573  raise x
3574  result = import_table_status_result()
3575  result.read(iprot)
3576  iprot.readMessageEnd()
3577  if result.success is not None:
3578  return result.success
3579  if result.e is not None:
3580  raise result.e
3581  raise TApplicationException(TApplicationException.MISSING_RESULT, "import_table_status failed: unknown result")
3582 
3583  def get_first_geo_file_in_archive(self, session, archive_path, copy_params):
3584  """
3585  Parameters:
3586  - session
3587  - archive_path
3588  - copy_params
3589 
3590  """
3591  self.send_get_first_geo_file_in_archive(session, archive_path, copy_params)
3593 
3594  def send_get_first_geo_file_in_archive(self, session, archive_path, copy_params):
3595  self._oprot.writeMessageBegin('get_first_geo_file_in_archive', TMessageType.CALL, self._seqid)
3597  args.session = session
3598  args.archive_path = archive_path
3599  args.copy_params = copy_params
3600  args.write(self._oprot)
3601  self._oprot.writeMessageEnd()
3602  self._oprot.trans.flush()
3603 
3605  iprot = self._iprot
3606  (fname, mtype, rseqid) = iprot.readMessageBegin()
3607  if mtype == TMessageType.EXCEPTION:
3608  x = TApplicationException()
3609  x.read(iprot)
3610  iprot.readMessageEnd()
3611  raise x
3613  result.read(iprot)
3614  iprot.readMessageEnd()
3615  if result.success is not None:
3616  return result.success
3617  if result.e is not None:
3618  raise result.e
3619  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_first_geo_file_in_archive failed: unknown result")
3620 
3621  def get_all_files_in_archive(self, session, archive_path, copy_params):
3622  """
3623  Parameters:
3624  - session
3625  - archive_path
3626  - copy_params
3627 
3628  """
3629  self.send_get_all_files_in_archive(session, archive_path, copy_params)
3630  return self.recv_get_all_files_in_archive()
3631 
3632  def send_get_all_files_in_archive(self, session, archive_path, copy_params):
3633  self._oprot.writeMessageBegin('get_all_files_in_archive', TMessageType.CALL, self._seqid)
3635  args.session = session
3636  args.archive_path = archive_path
3637  args.copy_params = copy_params
3638  args.write(self._oprot)
3639  self._oprot.writeMessageEnd()
3640  self._oprot.trans.flush()
3641 
3643  iprot = self._iprot
3644  (fname, mtype, rseqid) = iprot.readMessageBegin()
3645  if mtype == TMessageType.EXCEPTION:
3646  x = TApplicationException()
3647  x.read(iprot)
3648  iprot.readMessageEnd()
3649  raise x
3651  result.read(iprot)
3652  iprot.readMessageEnd()
3653  if result.success is not None:
3654  return result.success
3655  if result.e is not None:
3656  raise result.e
3657  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_all_files_in_archive failed: unknown result")
3658 
3659  def get_layers_in_geo_file(self, session, file_name, copy_params):
3660  """
3661  Parameters:
3662  - session
3663  - file_name
3664  - copy_params
3665 
3666  """
3667  self.send_get_layers_in_geo_file(session, file_name, copy_params)
3668  return self.recv_get_layers_in_geo_file()
3669 
3670  def send_get_layers_in_geo_file(self, session, file_name, copy_params):
3671  self._oprot.writeMessageBegin('get_layers_in_geo_file', TMessageType.CALL, self._seqid)
3673  args.session = session
3674  args.file_name = file_name
3675  args.copy_params = copy_params
3676  args.write(self._oprot)
3677  self._oprot.writeMessageEnd()
3678  self._oprot.trans.flush()
3679 
3681  iprot = self._iprot
3682  (fname, mtype, rseqid) = iprot.readMessageBegin()
3683  if mtype == TMessageType.EXCEPTION:
3684  x = TApplicationException()
3685  x.read(iprot)
3686  iprot.readMessageEnd()
3687  raise x
3689  result.read(iprot)
3690  iprot.readMessageEnd()
3691  if result.success is not None:
3692  return result.success
3693  if result.e is not None:
3694  raise result.e
3695  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_layers_in_geo_file failed: unknown result")
3696 
3697  def query_get_outer_fragment_count(self, session, query):
3698  """
3699  Parameters:
3700  - session
3701  - query
3702 
3703  """
3704  self.send_query_get_outer_fragment_count(session, query)
3706 
3707  def send_query_get_outer_fragment_count(self, session, query):
3708  self._oprot.writeMessageBegin('query_get_outer_fragment_count', TMessageType.CALL, self._seqid)
3710  args.session = session
3711  args.query = query
3712  args.write(self._oprot)
3713  self._oprot.writeMessageEnd()
3714  self._oprot.trans.flush()
3715 
3717  iprot = self._iprot
3718  (fname, mtype, rseqid) = iprot.readMessageBegin()
3719  if mtype == TMessageType.EXCEPTION:
3720  x = TApplicationException()
3721  x.read(iprot)
3722  iprot.readMessageEnd()
3723  raise x
3725  result.read(iprot)
3726  iprot.readMessageEnd()
3727  if result.success is not None:
3728  return result.success
3729  if result.e is not None:
3730  raise result.e
3731  raise TApplicationException(TApplicationException.MISSING_RESULT, "query_get_outer_fragment_count failed: unknown result")
3732 
3733  def check_table_consistency(self, session, table_id):
3734  """
3735  Parameters:
3736  - session
3737  - table_id
3738 
3739  """
3740  self.send_check_table_consistency(session, table_id)
3741  return self.recv_check_table_consistency()
3742 
3743  def send_check_table_consistency(self, session, table_id):
3744  self._oprot.writeMessageBegin('check_table_consistency', TMessageType.CALL, self._seqid)
3746  args.session = session
3747  args.table_id = table_id
3748  args.write(self._oprot)
3749  self._oprot.writeMessageEnd()
3750  self._oprot.trans.flush()
3751 
3753  iprot = self._iprot
3754  (fname, mtype, rseqid) = iprot.readMessageBegin()
3755  if mtype == TMessageType.EXCEPTION:
3756  x = TApplicationException()
3757  x.read(iprot)
3758  iprot.readMessageEnd()
3759  raise x
3761  result.read(iprot)
3762  iprot.readMessageEnd()
3763  if result.success is not None:
3764  return result.success
3765  if result.e is not None:
3766  raise result.e
3767  raise TApplicationException(TApplicationException.MISSING_RESULT, "check_table_consistency failed: unknown result")
3768 
3769  def start_query(self, leaf_session, parent_session, query_ra, start_time_str, just_explain, outer_fragment_indices):
3770  """
3771  Parameters:
3772  - leaf_session
3773  - parent_session
3774  - query_ra
3775  - start_time_str
3776  - just_explain
3777  - outer_fragment_indices
3778 
3779  """
3780  self.send_start_query(leaf_session, parent_session, query_ra, start_time_str, just_explain, outer_fragment_indices)
3781  return self.recv_start_query()
3782 
3783  def send_start_query(self, leaf_session, parent_session, query_ra, start_time_str, just_explain, outer_fragment_indices):
3784  self._oprot.writeMessageBegin('start_query', TMessageType.CALL, self._seqid)
3785  args = start_query_args()
3786  args.leaf_session = leaf_session
3787  args.parent_session = parent_session
3788  args.query_ra = query_ra
3789  args.start_time_str = start_time_str
3790  args.just_explain = just_explain
3791  args.outer_fragment_indices = outer_fragment_indices
3792  args.write(self._oprot)
3793  self._oprot.writeMessageEnd()
3794  self._oprot.trans.flush()
3795 
3796  def recv_start_query(self):
3797  iprot = self._iprot
3798  (fname, mtype, rseqid) = iprot.readMessageBegin()
3799  if mtype == TMessageType.EXCEPTION:
3800  x = TApplicationException()
3801  x.read(iprot)
3802  iprot.readMessageEnd()
3803  raise x
3804  result = start_query_result()
3805  result.read(iprot)
3806  iprot.readMessageEnd()
3807  if result.success is not None:
3808  return result.success
3809  if result.e is not None:
3810  raise result.e
3811  raise TApplicationException(TApplicationException.MISSING_RESULT, "start_query failed: unknown result")
3812 
3813  def execute_query_step(self, pending_query, subquery_id, start_time_str):
3814  """
3815  Parameters:
3816  - pending_query
3817  - subquery_id
3818  - start_time_str
3819 
3820  """
3821  self.send_execute_query_step(pending_query, subquery_id, start_time_str)
3822  return self.recv_execute_query_step()
3823 
3824  def send_execute_query_step(self, pending_query, subquery_id, start_time_str):
3825  self._oprot.writeMessageBegin('execute_query_step', TMessageType.CALL, self._seqid)
3826  args = execute_query_step_args()
3827  args.pending_query = pending_query
3828  args.subquery_id = subquery_id
3829  args.start_time_str = start_time_str
3830  args.write(self._oprot)
3831  self._oprot.writeMessageEnd()
3832  self._oprot.trans.flush()
3833 
3835  iprot = self._iprot
3836  (fname, mtype, rseqid) = iprot.readMessageBegin()
3837  if mtype == TMessageType.EXCEPTION:
3838  x = TApplicationException()
3839  x.read(iprot)
3840  iprot.readMessageEnd()
3841  raise x
3842  result = execute_query_step_result()
3843  result.read(iprot)
3844  iprot.readMessageEnd()
3845  if result.success is not None:
3846  return result.success
3847  if result.e is not None:
3848  raise result.e
3849  raise TApplicationException(TApplicationException.MISSING_RESULT, "execute_query_step failed: unknown result")
3850 
3851  def broadcast_serialized_rows(self, serialized_rows, row_desc, query_id, subquery_id, is_final_subquery_result):
3852  """
3853  Parameters:
3854  - serialized_rows
3855  - row_desc
3856  - query_id
3857  - subquery_id
3858  - is_final_subquery_result
3859 
3860  """
3861  self.send_broadcast_serialized_rows(serialized_rows, row_desc, query_id, subquery_id, is_final_subquery_result)
3863 
3864  def send_broadcast_serialized_rows(self, serialized_rows, row_desc, query_id, subquery_id, is_final_subquery_result):
3865  self._oprot.writeMessageBegin('broadcast_serialized_rows', TMessageType.CALL, self._seqid)
3867  args.serialized_rows = serialized_rows
3868  args.row_desc = row_desc
3869  args.query_id = query_id
3870  args.subquery_id = subquery_id
3871  args.is_final_subquery_result = is_final_subquery_result
3872  args.write(self._oprot)
3873  self._oprot.writeMessageEnd()
3874  self._oprot.trans.flush()
3875 
3877  iprot = self._iprot
3878  (fname, mtype, rseqid) = iprot.readMessageBegin()
3879  if mtype == TMessageType.EXCEPTION:
3880  x = TApplicationException()
3881  x.read(iprot)
3882  iprot.readMessageEnd()
3883  raise x
3885  result.read(iprot)
3886  iprot.readMessageEnd()
3887  if result.e is not None:
3888  raise result.e
3889  return
3890 
3891  def start_render_query(self, session, widget_id, node_idx, vega_json):
3892  """
3893  Parameters:
3894  - session
3895  - widget_id
3896  - node_idx
3897  - vega_json
3898 
3899  """
3900  self.send_start_render_query(session, widget_id, node_idx, vega_json)
3901  return self.recv_start_render_query()
3902 
3903  def send_start_render_query(self, session, widget_id, node_idx, vega_json):
3904  self._oprot.writeMessageBegin('start_render_query', TMessageType.CALL, self._seqid)
3905  args = start_render_query_args()
3906  args.session = session
3907  args.widget_id = widget_id
3908  args.node_idx = node_idx
3909  args.vega_json = vega_json
3910  args.write(self._oprot)
3911  self._oprot.writeMessageEnd()
3912  self._oprot.trans.flush()
3913 
3915  iprot = self._iprot
3916  (fname, mtype, rseqid) = iprot.readMessageBegin()
3917  if mtype == TMessageType.EXCEPTION:
3918  x = TApplicationException()
3919  x.read(iprot)
3920  iprot.readMessageEnd()
3921  raise x
3922  result = start_render_query_result()
3923  result.read(iprot)
3924  iprot.readMessageEnd()
3925  if result.success is not None:
3926  return result.success
3927  if result.e is not None:
3928  raise result.e
3929  raise TApplicationException(TApplicationException.MISSING_RESULT, "start_render_query failed: unknown result")
3930 
3931  def execute_next_render_step(self, pending_render, merged_data):
3932  """
3933  Parameters:
3934  - pending_render
3935  - merged_data
3936 
3937  """
3938  self.send_execute_next_render_step(pending_render, merged_data)
3939  return self.recv_execute_next_render_step()
3940 
3941  def send_execute_next_render_step(self, pending_render, merged_data):
3942  self._oprot.writeMessageBegin('execute_next_render_step', TMessageType.CALL, self._seqid)
3944  args.pending_render = pending_render
3945  args.merged_data = merged_data
3946  args.write(self._oprot)
3947  self._oprot.writeMessageEnd()
3948  self._oprot.trans.flush()
3949 
3951  iprot = self._iprot
3952  (fname, mtype, rseqid) = iprot.readMessageBegin()
3953  if mtype == TMessageType.EXCEPTION:
3954  x = TApplicationException()
3955  x.read(iprot)
3956  iprot.readMessageEnd()
3957  raise x
3959  result.read(iprot)
3960  iprot.readMessageEnd()
3961  if result.success is not None:
3962  return result.success
3963  if result.e is not None:
3964  raise result.e
3965  raise TApplicationException(TApplicationException.MISSING_RESULT, "execute_next_render_step failed: unknown result")
3966 
3967  def insert_data(self, session, insert_data):
3968  """
3969  Parameters:
3970  - session
3971  - insert_data
3972 
3973  """
3974  self.send_insert_data(session, insert_data)
3975  self.recv_insert_data()
3976 
3977  def send_insert_data(self, session, insert_data):
3978  self._oprot.writeMessageBegin('insert_data', TMessageType.CALL, self._seqid)
3979  args = insert_data_args()
3980  args.session = session
3981  args.insert_data = insert_data
3982  args.write(self._oprot)
3983  self._oprot.writeMessageEnd()
3984  self._oprot.trans.flush()
3985 
3986  def recv_insert_data(self):
3987  iprot = self._iprot
3988  (fname, mtype, rseqid) = iprot.readMessageBegin()
3989  if mtype == TMessageType.EXCEPTION:
3990  x = TApplicationException()
3991  x.read(iprot)
3992  iprot.readMessageEnd()
3993  raise x
3994  result = insert_data_result()
3995  result.read(iprot)
3996  iprot.readMessageEnd()
3997  if result.e is not None:
3998  raise result.e
3999  return
4000 
4001  def checkpoint(self, session, table_id):
4002  """
4003  Parameters:
4004  - session
4005  - table_id
4006 
4007  """
4008  self.send_checkpoint(session, table_id)
4009  self.recv_checkpoint()
4010 
4011  def send_checkpoint(self, session, table_id):
4012  self._oprot.writeMessageBegin('checkpoint', TMessageType.CALL, self._seqid)
4013  args = checkpoint_args()
4014  args.session = session
4015  args.table_id = table_id
4016  args.write(self._oprot)
4017  self._oprot.writeMessageEnd()
4018  self._oprot.trans.flush()
4019 
4020  def recv_checkpoint(self):
4021  iprot = self._iprot
4022  (fname, mtype, rseqid) = iprot.readMessageBegin()
4023  if mtype == TMessageType.EXCEPTION:
4024  x = TApplicationException()
4025  x.read(iprot)
4026  iprot.readMessageEnd()
4027  raise x
4028  result = checkpoint_result()
4029  result.read(iprot)
4030  iprot.readMessageEnd()
4031  if result.e is not None:
4032  raise result.e
4033  return
4034 
4035  def get_roles(self, session):
4036  """
4037  Parameters:
4038  - session
4039 
4040  """
4041  self.send_get_roles(session)
4042  return self.recv_get_roles()
4043 
4044  def send_get_roles(self, session):
4045  self._oprot.writeMessageBegin('get_roles', TMessageType.CALL, self._seqid)
4046  args = get_roles_args()
4047  args.session = session
4048  args.write(self._oprot)
4049  self._oprot.writeMessageEnd()
4050  self._oprot.trans.flush()
4051 
4052  def recv_get_roles(self):
4053  iprot = self._iprot
4054  (fname, mtype, rseqid) = iprot.readMessageBegin()
4055  if mtype == TMessageType.EXCEPTION:
4056  x = TApplicationException()
4057  x.read(iprot)
4058  iprot.readMessageEnd()
4059  raise x
4060  result = get_roles_result()
4061  result.read(iprot)
4062  iprot.readMessageEnd()
4063  if result.success is not None:
4064  return result.success
4065  if result.e is not None:
4066  raise result.e
4067  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_roles failed: unknown result")
4068 
4069  def get_db_objects_for_grantee(self, session, roleName):
4070  """
4071  Parameters:
4072  - session
4073  - roleName
4074 
4075  """
4076  self.send_get_db_objects_for_grantee(session, roleName)
4077  return self.recv_get_db_objects_for_grantee()
4078 
4079  def send_get_db_objects_for_grantee(self, session, roleName):
4080  self._oprot.writeMessageBegin('get_db_objects_for_grantee', TMessageType.CALL, self._seqid)
4082  args.session = session
4083  args.roleName = roleName
4084  args.write(self._oprot)
4085  self._oprot.writeMessageEnd()
4086  self._oprot.trans.flush()
4087 
4089  iprot = self._iprot
4090  (fname, mtype, rseqid) = iprot.readMessageBegin()
4091  if mtype == TMessageType.EXCEPTION:
4092  x = TApplicationException()
4093  x.read(iprot)
4094  iprot.readMessageEnd()
4095  raise x
4097  result.read(iprot)
4098  iprot.readMessageEnd()
4099  if result.success is not None:
4100  return result.success
4101  if result.e is not None:
4102  raise result.e
4103  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_db_objects_for_grantee failed: unknown result")
4104 
4105  def get_db_object_privs(self, session, objectName, type):
4106  """
4107  Parameters:
4108  - session
4109  - objectName
4110  - type
4111 
4112  """
4113  self.send_get_db_object_privs(session, objectName, type)
4114  return self.recv_get_db_object_privs()
4115 
4116  def send_get_db_object_privs(self, session, objectName, type):
4117  self._oprot.writeMessageBegin('get_db_object_privs', TMessageType.CALL, self._seqid)
4118  args = get_db_object_privs_args()
4119  args.session = session
4120  args.objectName = objectName
4121  args.type = type
4122  args.write(self._oprot)
4123  self._oprot.writeMessageEnd()
4124  self._oprot.trans.flush()
4125 
4127  iprot = self._iprot
4128  (fname, mtype, rseqid) = iprot.readMessageBegin()
4129  if mtype == TMessageType.EXCEPTION:
4130  x = TApplicationException()
4131  x.read(iprot)
4132  iprot.readMessageEnd()
4133  raise x
4134  result = get_db_object_privs_result()
4135  result.read(iprot)
4136  iprot.readMessageEnd()
4137  if result.success is not None:
4138  return result.success
4139  if result.e is not None:
4140  raise result.e
4141  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_db_object_privs failed: unknown result")
4142 
4143  def get_all_roles_for_user(self, session, userName):
4144  """
4145  Parameters:
4146  - session
4147  - userName
4148 
4149  """
4150  self.send_get_all_roles_for_user(session, userName)
4151  return self.recv_get_all_roles_for_user()
4152 
4153  def send_get_all_roles_for_user(self, session, userName):
4154  self._oprot.writeMessageBegin('get_all_roles_for_user', TMessageType.CALL, self._seqid)
4156  args.session = session
4157  args.userName = userName
4158  args.write(self._oprot)
4159  self._oprot.writeMessageEnd()
4160  self._oprot.trans.flush()
4161 
4163  iprot = self._iprot
4164  (fname, mtype, rseqid) = iprot.readMessageBegin()
4165  if mtype == TMessageType.EXCEPTION:
4166  x = TApplicationException()
4167  x.read(iprot)
4168  iprot.readMessageEnd()
4169  raise x
4171  result.read(iprot)
4172  iprot.readMessageEnd()
4173  if result.success is not None:
4174  return result.success
4175  if result.e is not None:
4176  raise result.e
4177  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_all_roles_for_user failed: unknown result")
4178 
4179  def has_role(self, session, granteeName, roleName):
4180  """
4181  Parameters:
4182  - session
4183  - granteeName
4184  - roleName
4185 
4186  """
4187  self.send_has_role(session, granteeName, roleName)
4188  return self.recv_has_role()
4189 
4190  def send_has_role(self, session, granteeName, roleName):
4191  self._oprot.writeMessageBegin('has_role', TMessageType.CALL, self._seqid)
4192  args = has_role_args()
4193  args.session = session
4194  args.granteeName = granteeName
4195  args.roleName = roleName
4196  args.write(self._oprot)
4197  self._oprot.writeMessageEnd()
4198  self._oprot.trans.flush()
4199 
4200  def recv_has_role(self):
4201  iprot = self._iprot
4202  (fname, mtype, rseqid) = iprot.readMessageBegin()
4203  if mtype == TMessageType.EXCEPTION:
4204  x = TApplicationException()
4205  x.read(iprot)
4206  iprot.readMessageEnd()
4207  raise x
4208  result = has_role_result()
4209  result.read(iprot)
4210  iprot.readMessageEnd()
4211  if result.success is not None:
4212  return result.success
4213  if result.e is not None:
4214  raise result.e
4215  raise TApplicationException(TApplicationException.MISSING_RESULT, "has_role failed: unknown result")
4216 
4217  def has_object_privilege(self, session, granteeName, ObjectName, objectType, permissions):
4218  """
4219  Parameters:
4220  - session
4221  - granteeName
4222  - ObjectName
4223  - objectType
4224  - permissions
4225 
4226  """
4227  self.send_has_object_privilege(session, granteeName, ObjectName, objectType, permissions)
4228  return self.recv_has_object_privilege()
4229 
4230  def send_has_object_privilege(self, session, granteeName, ObjectName, objectType, permissions):
4231  self._oprot.writeMessageBegin('has_object_privilege', TMessageType.CALL, self._seqid)
4232  args = has_object_privilege_args()
4233  args.session = session
4234  args.granteeName = granteeName
4235  args.ObjectName = ObjectName
4236  args.objectType = objectType
4237  args.permissions = permissions
4238  args.write(self._oprot)
4239  self._oprot.writeMessageEnd()
4240  self._oprot.trans.flush()
4241 
4243  iprot = self._iprot
4244  (fname, mtype, rseqid) = iprot.readMessageBegin()
4245  if mtype == TMessageType.EXCEPTION:
4246  x = TApplicationException()
4247  x.read(iprot)
4248  iprot.readMessageEnd()
4249  raise x
4250  result = has_object_privilege_result()
4251  result.read(iprot)
4252  iprot.readMessageEnd()
4253  if result.success is not None:
4254  return result.success
4255  if result.e is not None:
4256  raise result.e
4257  raise TApplicationException(TApplicationException.MISSING_RESULT, "has_object_privilege failed: unknown result")
4258 
4259  def set_license_key(self, session, key, nonce):
4260  """
4261  Parameters:
4262  - session
4263  - key
4264  - nonce
4265 
4266  """
4267  self.send_set_license_key(session, key, nonce)
4268  return self.recv_set_license_key()
4269 
4270  def send_set_license_key(self, session, key, nonce):
4271  self._oprot.writeMessageBegin('set_license_key', TMessageType.CALL, self._seqid)
4272  args = set_license_key_args()
4273  args.session = session
4274  args.key = key
4275  args.nonce = nonce
4276  args.write(self._oprot)
4277  self._oprot.writeMessageEnd()
4278  self._oprot.trans.flush()
4279 
4281  iprot = self._iprot
4282  (fname, mtype, rseqid) = iprot.readMessageBegin()
4283  if mtype == TMessageType.EXCEPTION:
4284  x = TApplicationException()
4285  x.read(iprot)
4286  iprot.readMessageEnd()
4287  raise x
4288  result = set_license_key_result()
4289  result.read(iprot)
4290  iprot.readMessageEnd()
4291  if result.success is not None:
4292  return result.success
4293  if result.e is not None:
4294  raise result.e
4295  raise TApplicationException(TApplicationException.MISSING_RESULT, "set_license_key failed: unknown result")
4296 
4297  def get_license_claims(self, session, nonce):
4298  """
4299  Parameters:
4300  - session
4301  - nonce
4302 
4303  """
4304  self.send_get_license_claims(session, nonce)
4305  return self.recv_get_license_claims()
4306 
4307  def send_get_license_claims(self, session, nonce):
4308  self._oprot.writeMessageBegin('get_license_claims', TMessageType.CALL, self._seqid)
4309  args = get_license_claims_args()
4310  args.session = session
4311  args.nonce = nonce
4312  args.write(self._oprot)
4313  self._oprot.writeMessageEnd()
4314  self._oprot.trans.flush()
4315 
4317  iprot = self._iprot
4318  (fname, mtype, rseqid) = iprot.readMessageBegin()
4319  if mtype == TMessageType.EXCEPTION:
4320  x = TApplicationException()
4321  x.read(iprot)
4322  iprot.readMessageEnd()
4323  raise x
4324  result = get_license_claims_result()
4325  result.read(iprot)
4326  iprot.readMessageEnd()
4327  if result.success is not None:
4328  return result.success
4329  if result.e is not None:
4330  raise result.e
4331  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_license_claims failed: unknown result")
4332 
4333  def get_device_parameters(self, session):
4334  """
4335  Parameters:
4336  - session
4337 
4338  """
4339  self.send_get_device_parameters(session)
4340  return self.recv_get_device_parameters()
4341 
4342  def send_get_device_parameters(self, session):
4343  self._oprot.writeMessageBegin('get_device_parameters', TMessageType.CALL, self._seqid)
4345  args.session = session
4346  args.write(self._oprot)
4347  self._oprot.writeMessageEnd()
4348  self._oprot.trans.flush()
4349 
4351  iprot = self._iprot
4352  (fname, mtype, rseqid) = iprot.readMessageBegin()
4353  if mtype == TMessageType.EXCEPTION:
4354  x = TApplicationException()
4355  x.read(iprot)
4356  iprot.readMessageEnd()
4357  raise x
4358  result = get_device_parameters_result()
4359  result.read(iprot)
4360  iprot.readMessageEnd()
4361  if result.success is not None:
4362  return result.success
4363  if result.e is not None:
4364  raise result.e
4365  raise TApplicationException(TApplicationException.MISSING_RESULT, "get_device_parameters failed: unknown result")
4366 
4367  def register_runtime_extension_functions(self, session, udfs, udtfs, device_ir_map):
4368  """
4369  Parameters:
4370  - session
4371  - udfs
4372  - udtfs
4373  - device_ir_map
4374 
4375  """
4376  self.send_register_runtime_extension_functions(session, udfs, udtfs, device_ir_map)
4378 
4379  def send_register_runtime_extension_functions(self, session, udfs, udtfs, device_ir_map):
4380  self._oprot.writeMessageBegin('register_runtime_extension_functions', TMessageType.CALL, self._seqid)
4382  args.session = session
4383  args.udfs = udfs
4384  args.udtfs = udtfs
4385  args.device_ir_map = device_ir_map
4386  args.write(self._oprot)
4387  self._oprot.writeMessageEnd()
4388  self._oprot.trans.flush()
4389 
4391  iprot = self._iprot
4392  (fname, mtype, rseqid) = iprot.readMessageBegin()
4393  if mtype == TMessageType.EXCEPTION:
4394  x = TApplicationException()
4395  x.read(iprot)
4396  iprot.readMessageEnd()
4397  raise x
4399  result.read(iprot)
4400  iprot.readMessageEnd()
4401  if result.e is not None:
4402  raise result.e
4403  return
4404 
4405 
4406 class Processor(Iface, TProcessor):
4407  def __init__(self, handler):
4408  self._handler = handler
4409  self._processMap = {}
4410  self._processMap["connect"] = Processor.process_connect
4411  self._processMap["krb5_connect"] = Processor.process_krb5_connect
4412  self._processMap["disconnect"] = Processor.process_disconnect
4413  self._processMap["switch_database"] = Processor.process_switch_database
4414  self._processMap["clone_session"] = Processor.process_clone_session
4415  self._processMap["get_server_status"] = Processor.process_get_server_status
4416  self._processMap["get_status"] = Processor.process_get_status
4417  self._processMap["get_hardware_info"] = Processor.process_get_hardware_info
4418  self._processMap["get_tables"] = Processor.process_get_tables
4419  self._processMap["get_tables_for_database"] = Processor.process_get_tables_for_database
4420  self._processMap["get_physical_tables"] = Processor.process_get_physical_tables
4421  self._processMap["get_views"] = Processor.process_get_views
4422  self._processMap["get_tables_meta"] = Processor.process_get_tables_meta
4423  self._processMap["get_table_details"] = Processor.process_get_table_details
4424  self._processMap["get_table_details_for_database"] = Processor.process_get_table_details_for_database
4425  self._processMap["get_internal_table_details"] = Processor.process_get_internal_table_details
4426  self._processMap["get_internal_table_details_for_database"] = Processor.process_get_internal_table_details_for_database
4427  self._processMap["get_users"] = Processor.process_get_users
4428  self._processMap["get_databases"] = Processor.process_get_databases
4429  self._processMap["get_version"] = Processor.process_get_version
4430  self._processMap["start_heap_profile"] = Processor.process_start_heap_profile
4431  self._processMap["stop_heap_profile"] = Processor.process_stop_heap_profile
4432  self._processMap["get_heap_profile"] = Processor.process_get_heap_profile
4433  self._processMap["get_memory"] = Processor.process_get_memory
4434  self._processMap["clear_cpu_memory"] = Processor.process_clear_cpu_memory
4435  self._processMap["clear_gpu_memory"] = Processor.process_clear_gpu_memory
4436  self._processMap["set_cur_session"] = Processor.process_set_cur_session
4437  self._processMap["invalidate_cur_session"] = Processor.process_invalidate_cur_session
4438  self._processMap["set_table_epoch"] = Processor.process_set_table_epoch
4439  self._processMap["set_table_epoch_by_name"] = Processor.process_set_table_epoch_by_name
4440  self._processMap["get_table_epoch"] = Processor.process_get_table_epoch
4441  self._processMap["get_table_epoch_by_name"] = Processor.process_get_table_epoch_by_name
4442  self._processMap["get_table_epochs"] = Processor.process_get_table_epochs
4443  self._processMap["set_table_epochs"] = Processor.process_set_table_epochs
4444  self._processMap["get_session_info"] = Processor.process_get_session_info
4445  self._processMap["sql_execute"] = Processor.process_sql_execute
4446  self._processMap["sql_execute_df"] = Processor.process_sql_execute_df
4447  self._processMap["sql_execute_gdf"] = Processor.process_sql_execute_gdf
4448  self._processMap["deallocate_df"] = Processor.process_deallocate_df
4449  self._processMap["interrupt"] = Processor.process_interrupt
4450  self._processMap["sql_validate"] = Processor.process_sql_validate
4451  self._processMap["get_completion_hints"] = Processor.process_get_completion_hints
4452  self._processMap["set_execution_mode"] = Processor.process_set_execution_mode
4453  self._processMap["render_vega"] = Processor.process_render_vega
4454  self._processMap["get_result_row_for_pixel"] = Processor.process_get_result_row_for_pixel
4455  self._processMap["create_custom_expression"] = Processor.process_create_custom_expression
4456  self._processMap["get_custom_expressions"] = Processor.process_get_custom_expressions
4457  self._processMap["update_custom_expression"] = Processor.process_update_custom_expression
4458  self._processMap["delete_custom_expressions"] = Processor.process_delete_custom_expressions
4459  self._processMap["get_dashboard"] = Processor.process_get_dashboard
4460  self._processMap["get_dashboards"] = Processor.process_get_dashboards
4461  self._processMap["create_dashboard"] = Processor.process_create_dashboard
4462  self._processMap["replace_dashboard"] = Processor.process_replace_dashboard
4463  self._processMap["delete_dashboard"] = Processor.process_delete_dashboard
4464  self._processMap["share_dashboards"] = Processor.process_share_dashboards
4465  self._processMap["delete_dashboards"] = Processor.process_delete_dashboards
4466  self._processMap["share_dashboard"] = Processor.process_share_dashboard
4467  self._processMap["unshare_dashboard"] = Processor.process_unshare_dashboard
4468  self._processMap["unshare_dashboards"] = Processor.process_unshare_dashboards
4469  self._processMap["get_dashboard_grantees"] = Processor.process_get_dashboard_grantees
4470  self._processMap["get_link_view"] = Processor.process_get_link_view
4471  self._processMap["create_link"] = Processor.process_create_link
4472  self._processMap["load_table_binary"] = Processor.process_load_table_binary
4473  self._processMap["load_table_binary_columnar"] = Processor.process_load_table_binary_columnar
4474  self._processMap["load_table_binary_columnar_polys"] = Processor.process_load_table_binary_columnar_polys
4475  self._processMap["load_table_binary_arrow"] = Processor.process_load_table_binary_arrow
4476  self._processMap["load_table"] = Processor.process_load_table
4477  self._processMap["detect_column_types"] = Processor.process_detect_column_types
4478  self._processMap["create_table"] = Processor.process_create_table
4479  self._processMap["import_table"] = Processor.process_import_table
4480  self._processMap["import_geo_table"] = Processor.process_import_geo_table
4481  self._processMap["import_table_status"] = Processor.process_import_table_status
4482  self._processMap["get_first_geo_file_in_archive"] = Processor.process_get_first_geo_file_in_archive
4483  self._processMap["get_all_files_in_archive"] = Processor.process_get_all_files_in_archive
4484  self._processMap["get_layers_in_geo_file"] = Processor.process_get_layers_in_geo_file
4485  self._processMap["query_get_outer_fragment_count"] = Processor.process_query_get_outer_fragment_count
4486  self._processMap["check_table_consistency"] = Processor.process_check_table_consistency
4487  self._processMap["start_query"] = Processor.process_start_query
4488  self._processMap["execute_query_step"] = Processor.process_execute_query_step
4489  self._processMap["broadcast_serialized_rows"] = Processor.process_broadcast_serialized_rows
4490  self._processMap["start_render_query"] = Processor.process_start_render_query
4491  self._processMap["execute_next_render_step"] = Processor.process_execute_next_render_step
4492  self._processMap["insert_data"] = Processor.process_insert_data
4493  self._processMap["checkpoint"] = Processor.process_checkpoint
4494  self._processMap["get_roles"] = Processor.process_get_roles
4495  self._processMap["get_db_objects_for_grantee"] = Processor.process_get_db_objects_for_grantee
4496  self._processMap["get_db_object_privs"] = Processor.process_get_db_object_privs
4497  self._processMap["get_all_roles_for_user"] = Processor.process_get_all_roles_for_user
4498  self._processMap["has_role"] = Processor.process_has_role
4499  self._processMap["has_object_privilege"] = Processor.process_has_object_privilege
4500  self._processMap["set_license_key"] = Processor.process_set_license_key
4501  self._processMap["get_license_claims"] = Processor.process_get_license_claims
4502  self._processMap["get_device_parameters"] = Processor.process_get_device_parameters
4503  self._processMap["register_runtime_extension_functions"] = Processor.process_register_runtime_extension_functions
4504  self._on_message_begin = None
4505 
4506  def on_message_begin(self, func):
4507  self._on_message_begin = func
4508 
4509  def process(self, iprot, oprot):
4510  (name, type, seqid) = iprot.readMessageBegin()
4511  if self._on_message_begin:
4512  self._on_message_begin(name, type, seqid)
4513  if name not in self._processMap:
4514  iprot.skip(TType.STRUCT)
4515  iprot.readMessageEnd()
4516  x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
4517  oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
4518  x.write(oprot)
4519  oprot.writeMessageEnd()
4520  oprot.trans.flush()
4521  return
4522  else:
4523  self._processMap[name](self, seqid, iprot, oprot)
4524  return True
4525 
4526  def process_connect(self, seqid, iprot, oprot):
4527  args = connect_args()
4528  args.read(iprot)
4529  iprot.readMessageEnd()
4530  result = connect_result()
4531  try:
4532  result.success = self._handler.connect(args.user, args.passwd, args.dbname)
4533  msg_type = TMessageType.REPLY
4534  except TTransport.TTransportException:
4535  raise
4536  except TOmniSciException as e:
4537  msg_type = TMessageType.REPLY
4538  result.e = e
4539  except TApplicationException as ex:
4540  logging.exception('TApplication exception in handler')
4541  msg_type = TMessageType.EXCEPTION
4542  result = ex
4543  except Exception:
4544  logging.exception('Unexpected exception in handler')
4545  msg_type = TMessageType.EXCEPTION
4546  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4547  oprot.writeMessageBegin("connect", msg_type, seqid)
4548  result.write(oprot)
4549  oprot.writeMessageEnd()
4550  oprot.trans.flush()
4551 
4552  def process_krb5_connect(self, seqid, iprot, oprot):
4553  args = krb5_connect_args()
4554  args.read(iprot)
4555  iprot.readMessageEnd()
4556  result = krb5_connect_result()
4557  try:
4558  result.success = self._handler.krb5_connect(args.inputToken, args.dbname)
4559  msg_type = TMessageType.REPLY
4560  except TTransport.TTransportException:
4561  raise
4562  except TOmniSciException as e:
4563  msg_type = TMessageType.REPLY
4564  result.e = e
4565  except TApplicationException as ex:
4566  logging.exception('TApplication exception in handler')
4567  msg_type = TMessageType.EXCEPTION
4568  result = ex
4569  except Exception:
4570  logging.exception('Unexpected exception in handler')
4571  msg_type = TMessageType.EXCEPTION
4572  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4573  oprot.writeMessageBegin("krb5_connect", msg_type, seqid)
4574  result.write(oprot)
4575  oprot.writeMessageEnd()
4576  oprot.trans.flush()
4577 
4578  def process_disconnect(self, seqid, iprot, oprot):
4579  args = disconnect_args()
4580  args.read(iprot)
4581  iprot.readMessageEnd()
4582  result = disconnect_result()
4583  try:
4584  self._handler.disconnect(args.session)
4585  msg_type = TMessageType.REPLY
4586  except TTransport.TTransportException:
4587  raise
4588  except TOmniSciException as e:
4589  msg_type = TMessageType.REPLY
4590  result.e = e
4591  except TApplicationException as ex:
4592  logging.exception('TApplication exception in handler')
4593  msg_type = TMessageType.EXCEPTION
4594  result = ex
4595  except Exception:
4596  logging.exception('Unexpected exception in handler')
4597  msg_type = TMessageType.EXCEPTION
4598  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4599  oprot.writeMessageBegin("disconnect", msg_type, seqid)
4600  result.write(oprot)
4601  oprot.writeMessageEnd()
4602  oprot.trans.flush()
4603 
4604  def process_switch_database(self, seqid, iprot, oprot):
4605  args = switch_database_args()
4606  args.read(iprot)
4607  iprot.readMessageEnd()
4608  result = switch_database_result()
4609  try:
4610  self._handler.switch_database(args.session, args.dbname)
4611  msg_type = TMessageType.REPLY
4612  except TTransport.TTransportException:
4613  raise
4614  except TOmniSciException as e:
4615  msg_type = TMessageType.REPLY
4616  result.e = e
4617  except TApplicationException as ex:
4618  logging.exception('TApplication exception in handler')
4619  msg_type = TMessageType.EXCEPTION
4620  result = ex
4621  except Exception:
4622  logging.exception('Unexpected exception in handler')
4623  msg_type = TMessageType.EXCEPTION
4624  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4625  oprot.writeMessageBegin("switch_database", msg_type, seqid)
4626  result.write(oprot)
4627  oprot.writeMessageEnd()
4628  oprot.trans.flush()
4629 
4630  def process_clone_session(self, seqid, iprot, oprot):
4631  args = clone_session_args()
4632  args.read(iprot)
4633  iprot.readMessageEnd()
4634  result = clone_session_result()
4635  try:
4636  result.success = self._handler.clone_session(args.session)
4637  msg_type = TMessageType.REPLY
4638  except TTransport.TTransportException:
4639  raise
4640  except TOmniSciException as e:
4641  msg_type = TMessageType.REPLY
4642  result.e = e
4643  except TApplicationException as ex:
4644  logging.exception('TApplication exception in handler')
4645  msg_type = TMessageType.EXCEPTION
4646  result = ex
4647  except Exception:
4648  logging.exception('Unexpected exception in handler')
4649  msg_type = TMessageType.EXCEPTION
4650  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4651  oprot.writeMessageBegin("clone_session", msg_type, seqid)
4652  result.write(oprot)
4653  oprot.writeMessageEnd()
4654  oprot.trans.flush()
4655 
4656  def process_get_server_status(self, seqid, iprot, oprot):
4657  args = get_server_status_args()
4658  args.read(iprot)
4659  iprot.readMessageEnd()
4660  result = get_server_status_result()
4661  try:
4662  result.success = self._handler.get_server_status(args.session)
4663  msg_type = TMessageType.REPLY
4664  except TTransport.TTransportException:
4665  raise
4666  except TOmniSciException as e:
4667  msg_type = TMessageType.REPLY
4668  result.e = e
4669  except TApplicationException as ex:
4670  logging.exception('TApplication exception in handler')
4671  msg_type = TMessageType.EXCEPTION
4672  result = ex
4673  except Exception:
4674  logging.exception('Unexpected exception in handler')
4675  msg_type = TMessageType.EXCEPTION
4676  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4677  oprot.writeMessageBegin("get_server_status", msg_type, seqid)
4678  result.write(oprot)
4679  oprot.writeMessageEnd()
4680  oprot.trans.flush()
4681 
4682  def process_get_status(self, seqid, iprot, oprot):
4683  args = get_status_args()
4684  args.read(iprot)
4685  iprot.readMessageEnd()
4686  result = get_status_result()
4687  try:
4688  result.success = self._handler.get_status(args.session)
4689  msg_type = TMessageType.REPLY
4690  except TTransport.TTransportException:
4691  raise
4692  except TOmniSciException as e:
4693  msg_type = TMessageType.REPLY
4694  result.e = e
4695  except TApplicationException as ex:
4696  logging.exception('TApplication exception in handler')
4697  msg_type = TMessageType.EXCEPTION
4698  result = ex
4699  except Exception:
4700  logging.exception('Unexpected exception in handler')
4701  msg_type = TMessageType.EXCEPTION
4702  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4703  oprot.writeMessageBegin("get_status", msg_type, seqid)
4704  result.write(oprot)
4705  oprot.writeMessageEnd()
4706  oprot.trans.flush()
4707 
4708  def process_get_hardware_info(self, seqid, iprot, oprot):
4709  args = get_hardware_info_args()
4710  args.read(iprot)
4711  iprot.readMessageEnd()
4712  result = get_hardware_info_result()
4713  try:
4714  result.success = self._handler.get_hardware_info(args.session)
4715  msg_type = TMessageType.REPLY
4716  except TTransport.TTransportException:
4717  raise
4718  except TOmniSciException as e:
4719  msg_type = TMessageType.REPLY
4720  result.e = e
4721  except TApplicationException as ex:
4722  logging.exception('TApplication exception in handler')
4723  msg_type = TMessageType.EXCEPTION
4724  result = ex
4725  except Exception:
4726  logging.exception('Unexpected exception in handler')
4727  msg_type = TMessageType.EXCEPTION
4728  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4729  oprot.writeMessageBegin("get_hardware_info", msg_type, seqid)
4730  result.write(oprot)
4731  oprot.writeMessageEnd()
4732  oprot.trans.flush()
4733 
4734  def process_get_tables(self, seqid, iprot, oprot):
4735  args = get_tables_args()
4736  args.read(iprot)
4737  iprot.readMessageEnd()
4738  result = get_tables_result()
4739  try:
4740  result.success = self._handler.get_tables(args.session)
4741  msg_type = TMessageType.REPLY
4742  except TTransport.TTransportException:
4743  raise
4744  except TOmniSciException as e:
4745  msg_type = TMessageType.REPLY
4746  result.e = e
4747  except TApplicationException as ex:
4748  logging.exception('TApplication exception in handler')
4749  msg_type = TMessageType.EXCEPTION
4750  result = ex
4751  except Exception:
4752  logging.exception('Unexpected exception in handler')
4753  msg_type = TMessageType.EXCEPTION
4754  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4755  oprot.writeMessageBegin("get_tables", msg_type, seqid)
4756  result.write(oprot)
4757  oprot.writeMessageEnd()
4758  oprot.trans.flush()
4759 
4760  def process_get_tables_for_database(self, seqid, iprot, oprot):
4762  args.read(iprot)
4763  iprot.readMessageEnd()
4765  try:
4766  result.success = self._handler.get_tables_for_database(args.session, args.database_name)
4767  msg_type = TMessageType.REPLY
4768  except TTransport.TTransportException:
4769  raise
4770  except TOmniSciException as e:
4771  msg_type = TMessageType.REPLY
4772  result.e = e
4773  except TApplicationException as ex:
4774  logging.exception('TApplication exception in handler')
4775  msg_type = TMessageType.EXCEPTION
4776  result = ex
4777  except Exception:
4778  logging.exception('Unexpected exception in handler')
4779  msg_type = TMessageType.EXCEPTION
4780  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4781  oprot.writeMessageBegin("get_tables_for_database", msg_type, seqid)
4782  result.write(oprot)
4783  oprot.writeMessageEnd()
4784  oprot.trans.flush()
4785 
4786  def process_get_physical_tables(self, seqid, iprot, oprot):
4787  args = get_physical_tables_args()
4788  args.read(iprot)
4789  iprot.readMessageEnd()
4790  result = get_physical_tables_result()
4791  try:
4792  result.success = self._handler.get_physical_tables(args.session)
4793  msg_type = TMessageType.REPLY
4794  except TTransport.TTransportException:
4795  raise
4796  except TOmniSciException as e:
4797  msg_type = TMessageType.REPLY
4798  result.e = e
4799  except TApplicationException as ex:
4800  logging.exception('TApplication exception in handler')
4801  msg_type = TMessageType.EXCEPTION
4802  result = ex
4803  except Exception:
4804  logging.exception('Unexpected exception in handler')
4805  msg_type = TMessageType.EXCEPTION
4806  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4807  oprot.writeMessageBegin("get_physical_tables", msg_type, seqid)
4808  result.write(oprot)
4809  oprot.writeMessageEnd()
4810  oprot.trans.flush()
4811 
4812  def process_get_views(self, seqid, iprot, oprot):
4813  args = get_views_args()
4814  args.read(iprot)
4815  iprot.readMessageEnd()
4816  result = get_views_result()
4817  try:
4818  result.success = self._handler.get_views(args.session)
4819  msg_type = TMessageType.REPLY
4820  except TTransport.TTransportException:
4821  raise
4822  except TOmniSciException as e:
4823  msg_type = TMessageType.REPLY
4824  result.e = e
4825  except TApplicationException as ex:
4826  logging.exception('TApplication exception in handler')
4827  msg_type = TMessageType.EXCEPTION
4828  result = ex
4829  except Exception:
4830  logging.exception('Unexpected exception in handler')
4831  msg_type = TMessageType.EXCEPTION
4832  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4833  oprot.writeMessageBegin("get_views", msg_type, seqid)
4834  result.write(oprot)
4835  oprot.writeMessageEnd()
4836  oprot.trans.flush()
4837 
4838  def process_get_tables_meta(self, seqid, iprot, oprot):
4839  args = get_tables_meta_args()
4840  args.read(iprot)
4841  iprot.readMessageEnd()
4842  result = get_tables_meta_result()
4843  try:
4844  result.success = self._handler.get_tables_meta(args.session)
4845  msg_type = TMessageType.REPLY
4846  except TTransport.TTransportException:
4847  raise
4848  except TOmniSciException as e:
4849  msg_type = TMessageType.REPLY
4850  result.e = e
4851  except TApplicationException as ex:
4852  logging.exception('TApplication exception in handler')
4853  msg_type = TMessageType.EXCEPTION
4854  result = ex
4855  except Exception:
4856  logging.exception('Unexpected exception in handler')
4857  msg_type = TMessageType.EXCEPTION
4858  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4859  oprot.writeMessageBegin("get_tables_meta", msg_type, seqid)
4860  result.write(oprot)
4861  oprot.writeMessageEnd()
4862  oprot.trans.flush()
4863 
4864  def process_get_table_details(self, seqid, iprot, oprot):
4865  args = get_table_details_args()
4866  args.read(iprot)
4867  iprot.readMessageEnd()
4868  result = get_table_details_result()
4869  try:
4870  result.success = self._handler.get_table_details(args.session, args.table_name)
4871  msg_type = TMessageType.REPLY
4872  except TTransport.TTransportException:
4873  raise
4874  except TOmniSciException as e:
4875  msg_type = TMessageType.REPLY
4876  result.e = e
4877  except TApplicationException as ex:
4878  logging.exception('TApplication exception in handler')
4879  msg_type = TMessageType.EXCEPTION
4880  result = ex
4881  except Exception:
4882  logging.exception('Unexpected exception in handler')
4883  msg_type = TMessageType.EXCEPTION
4884  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4885  oprot.writeMessageBegin("get_table_details", msg_type, seqid)
4886  result.write(oprot)
4887  oprot.writeMessageEnd()
4888  oprot.trans.flush()
4889 
4890  def process_get_table_details_for_database(self, seqid, iprot, oprot):
4892  args.read(iprot)
4893  iprot.readMessageEnd()
4895  try:
4896  result.success = self._handler.get_table_details_for_database(args.session, args.table_name, args.database_name)
4897  msg_type = TMessageType.REPLY
4898  except TTransport.TTransportException:
4899  raise
4900  except TOmniSciException as e:
4901  msg_type = TMessageType.REPLY
4902  result.e = e
4903  except TApplicationException as ex:
4904  logging.exception('TApplication exception in handler')
4905  msg_type = TMessageType.EXCEPTION
4906  result = ex
4907  except Exception:
4908  logging.exception('Unexpected exception in handler')
4909  msg_type = TMessageType.EXCEPTION
4910  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4911  oprot.writeMessageBegin("get_table_details_for_database", msg_type, seqid)
4912  result.write(oprot)
4913  oprot.writeMessageEnd()
4914  oprot.trans.flush()
4915 
4916  def process_get_internal_table_details(self, seqid, iprot, oprot):
4918  args.read(iprot)
4919  iprot.readMessageEnd()
4921  try:
4922  result.success = self._handler.get_internal_table_details(args.session, args.table_name)
4923  msg_type = TMessageType.REPLY
4924  except TTransport.TTransportException:
4925  raise
4926  except TOmniSciException as e:
4927  msg_type = TMessageType.REPLY
4928  result.e = e
4929  except TApplicationException as ex:
4930  logging.exception('TApplication exception in handler')
4931  msg_type = TMessageType.EXCEPTION
4932  result = ex
4933  except Exception:
4934  logging.exception('Unexpected exception in handler')
4935  msg_type = TMessageType.EXCEPTION
4936  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4937  oprot.writeMessageBegin("get_internal_table_details", msg_type, seqid)
4938  result.write(oprot)
4939  oprot.writeMessageEnd()
4940  oprot.trans.flush()
4941 
4942  def process_get_internal_table_details_for_database(self, seqid, iprot, oprot):
4944  args.read(iprot)
4945  iprot.readMessageEnd()
4947  try:
4948  result.success = self._handler.get_internal_table_details_for_database(args.session, args.table_name, args.database_name)
4949  msg_type = TMessageType.REPLY
4950  except TTransport.TTransportException:
4951  raise
4952  except TOmniSciException as e:
4953  msg_type = TMessageType.REPLY
4954  result.e = e
4955  except TApplicationException as ex:
4956  logging.exception('TApplication exception in handler')
4957  msg_type = TMessageType.EXCEPTION
4958  result = ex
4959  except Exception:
4960  logging.exception('Unexpected exception in handler')
4961  msg_type = TMessageType.EXCEPTION
4962  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4963  oprot.writeMessageBegin("get_internal_table_details_for_database", msg_type, seqid)
4964  result.write(oprot)
4965  oprot.writeMessageEnd()
4966  oprot.trans.flush()
4967 
4968  def process_get_users(self, seqid, iprot, oprot):
4969  args = get_users_args()
4970  args.read(iprot)
4971  iprot.readMessageEnd()
4972  result = get_users_result()
4973  try:
4974  result.success = self._handler.get_users(args.session)
4975  msg_type = TMessageType.REPLY
4976  except TTransport.TTransportException:
4977  raise
4978  except TOmniSciException as e:
4979  msg_type = TMessageType.REPLY
4980  result.e = e
4981  except TApplicationException as ex:
4982  logging.exception('TApplication exception in handler')
4983  msg_type = TMessageType.EXCEPTION
4984  result = ex
4985  except Exception:
4986  logging.exception('Unexpected exception in handler')
4987  msg_type = TMessageType.EXCEPTION
4988  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
4989  oprot.writeMessageBegin("get_users", msg_type, seqid)
4990  result.write(oprot)
4991  oprot.writeMessageEnd()
4992  oprot.trans.flush()
4993 
4994  def process_get_databases(self, seqid, iprot, oprot):
4995  args = get_databases_args()
4996  args.read(iprot)
4997  iprot.readMessageEnd()
4998  result = get_databases_result()
4999  try:
5000  result.success = self._handler.get_databases(args.session)
5001  msg_type = TMessageType.REPLY
5002  except TTransport.TTransportException:
5003  raise
5004  except TOmniSciException as e:
5005  msg_type = TMessageType.REPLY
5006  result.e = e
5007  except TApplicationException as ex:
5008  logging.exception('TApplication exception in handler')
5009  msg_type = TMessageType.EXCEPTION
5010  result = ex
5011  except Exception:
5012  logging.exception('Unexpected exception in handler')
5013  msg_type = TMessageType.EXCEPTION
5014  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5015  oprot.writeMessageBegin("get_databases", msg_type, seqid)
5016  result.write(oprot)
5017  oprot.writeMessageEnd()
5018  oprot.trans.flush()
5019 
5020  def process_get_version(self, seqid, iprot, oprot):
5021  args = get_version_args()
5022  args.read(iprot)
5023  iprot.readMessageEnd()
5024  result = get_version_result()
5025  try:
5026  result.success = self._handler.get_version()
5027  msg_type = TMessageType.REPLY
5028  except TTransport.TTransportException:
5029  raise
5030  except TOmniSciException as e:
5031  msg_type = TMessageType.REPLY
5032  result.e = e
5033  except TApplicationException as ex:
5034  logging.exception('TApplication exception in handler')
5035  msg_type = TMessageType.EXCEPTION
5036  result = ex
5037  except Exception:
5038  logging.exception('Unexpected exception in handler')
5039  msg_type = TMessageType.EXCEPTION
5040  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5041  oprot.writeMessageBegin("get_version", msg_type, seqid)
5042  result.write(oprot)
5043  oprot.writeMessageEnd()
5044  oprot.trans.flush()
5045 
5046  def process_start_heap_profile(self, seqid, iprot, oprot):
5047  args = start_heap_profile_args()
5048  args.read(iprot)
5049  iprot.readMessageEnd()
5050  result = start_heap_profile_result()
5051  try:
5052  self._handler.start_heap_profile(args.session)
5053  msg_type = TMessageType.REPLY
5054  except TTransport.TTransportException:
5055  raise
5056  except TOmniSciException as e:
5057  msg_type = TMessageType.REPLY
5058  result.e = e
5059  except TApplicationException as ex:
5060  logging.exception('TApplication exception in handler')
5061  msg_type = TMessageType.EXCEPTION
5062  result = ex
5063  except Exception:
5064  logging.exception('Unexpected exception in handler')
5065  msg_type = TMessageType.EXCEPTION
5066  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5067  oprot.writeMessageBegin("start_heap_profile", msg_type, seqid)
5068  result.write(oprot)
5069  oprot.writeMessageEnd()
5070  oprot.trans.flush()
5071 
5072  def process_stop_heap_profile(self, seqid, iprot, oprot):
5073  args = stop_heap_profile_args()
5074  args.read(iprot)
5075  iprot.readMessageEnd()
5076  result = stop_heap_profile_result()
5077  try:
5078  self._handler.stop_heap_profile(args.session)
5079  msg_type = TMessageType.REPLY
5080  except TTransport.TTransportException:
5081  raise
5082  except TOmniSciException as e:
5083  msg_type = TMessageType.REPLY
5084  result.e = e
5085  except TApplicationException as ex:
5086  logging.exception('TApplication exception in handler')
5087  msg_type = TMessageType.EXCEPTION
5088  result = ex
5089  except Exception:
5090  logging.exception('Unexpected exception in handler')
5091  msg_type = TMessageType.EXCEPTION
5092  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5093  oprot.writeMessageBegin("stop_heap_profile", msg_type, seqid)
5094  result.write(oprot)
5095  oprot.writeMessageEnd()
5096  oprot.trans.flush()
5097 
5098  def process_get_heap_profile(self, seqid, iprot, oprot):
5099  args = get_heap_profile_args()
5100  args.read(iprot)
5101  iprot.readMessageEnd()
5102  result = get_heap_profile_result()
5103  try:
5104  result.success = self._handler.get_heap_profile(args.session)
5105  msg_type = TMessageType.REPLY
5106  except TTransport.TTransportException:
5107  raise
5108  except TOmniSciException as e:
5109  msg_type = TMessageType.REPLY
5110  result.e = e
5111  except TApplicationException as ex:
5112  logging.exception('TApplication exception in handler')
5113  msg_type = TMessageType.EXCEPTION
5114  result = ex
5115  except Exception:
5116  logging.exception('Unexpected exception in handler')
5117  msg_type = TMessageType.EXCEPTION
5118  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5119  oprot.writeMessageBegin("get_heap_profile", msg_type, seqid)
5120  result.write(oprot)
5121  oprot.writeMessageEnd()
5122  oprot.trans.flush()
5123 
5124  def process_get_memory(self, seqid, iprot, oprot):
5125  args = get_memory_args()
5126  args.read(iprot)
5127  iprot.readMessageEnd()
5128  result = get_memory_result()
5129  try:
5130  result.success = self._handler.get_memory(args.session, args.memory_level)
5131  msg_type = TMessageType.REPLY
5132  except TTransport.TTransportException:
5133  raise
5134  except TOmniSciException as e:
5135  msg_type = TMessageType.REPLY
5136  result.e = e
5137  except TApplicationException as ex:
5138  logging.exception('TApplication exception in handler')
5139  msg_type = TMessageType.EXCEPTION
5140  result = ex
5141  except Exception:
5142  logging.exception('Unexpected exception in handler')
5143  msg_type = TMessageType.EXCEPTION
5144  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5145  oprot.writeMessageBegin("get_memory", msg_type, seqid)
5146  result.write(oprot)
5147  oprot.writeMessageEnd()
5148  oprot.trans.flush()
5149 
5150  def process_clear_cpu_memory(self, seqid, iprot, oprot):
5151  args = clear_cpu_memory_args()
5152  args.read(iprot)
5153  iprot.readMessageEnd()
5154  result = clear_cpu_memory_result()
5155  try:
5156  self._handler.clear_cpu_memory(args.session)
5157  msg_type = TMessageType.REPLY
5158  except TTransport.TTransportException:
5159  raise
5160  except TOmniSciException as e:
5161  msg_type = TMessageType.REPLY
5162  result.e = e
5163  except TApplicationException as ex:
5164  logging.exception('TApplication exception in handler')
5165  msg_type = TMessageType.EXCEPTION
5166  result = ex
5167  except Exception:
5168  logging.exception('Unexpected exception in handler')
5169  msg_type = TMessageType.EXCEPTION
5170  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5171  oprot.writeMessageBegin("clear_cpu_memory", msg_type, seqid)
5172  result.write(oprot)
5173  oprot.writeMessageEnd()
5174  oprot.trans.flush()
5175 
5176  def process_clear_gpu_memory(self, seqid, iprot, oprot):
5177  args = clear_gpu_memory_args()
5178  args.read(iprot)
5179  iprot.readMessageEnd()
5180  result = clear_gpu_memory_result()
5181  try:
5182  self._handler.clear_gpu_memory(args.session)
5183  msg_type = TMessageType.REPLY
5184  except TTransport.TTransportException:
5185  raise
5186  except TOmniSciException as e:
5187  msg_type = TMessageType.REPLY
5188  result.e = e
5189  except TApplicationException as ex:
5190  logging.exception('TApplication exception in handler')
5191  msg_type = TMessageType.EXCEPTION
5192  result = ex
5193  except Exception:
5194  logging.exception('Unexpected exception in handler')
5195  msg_type = TMessageType.EXCEPTION
5196  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5197  oprot.writeMessageBegin("clear_gpu_memory", msg_type, seqid)
5198  result.write(oprot)
5199  oprot.writeMessageEnd()
5200  oprot.trans.flush()
5201 
5202  def process_set_cur_session(self, seqid, iprot, oprot):
5203  args = set_cur_session_args()
5204  args.read(iprot)
5205  iprot.readMessageEnd()
5206  result = set_cur_session_result()
5207  try:
5208  self._handler.set_cur_session(args.parent_session, args.leaf_session, args.start_time_str, args.label, args.for_running_query_kernel)
5209  msg_type = TMessageType.REPLY
5210  except TTransport.TTransportException:
5211  raise
5212  except TOmniSciException as e:
5213  msg_type = TMessageType.REPLY
5214  result.e = e
5215  except TApplicationException as ex:
5216  logging.exception('TApplication exception in handler')
5217  msg_type = TMessageType.EXCEPTION
5218  result = ex
5219  except Exception:
5220  logging.exception('Unexpected exception in handler')
5221  msg_type = TMessageType.EXCEPTION
5222  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5223  oprot.writeMessageBegin("set_cur_session", msg_type, seqid)
5224  result.write(oprot)
5225  oprot.writeMessageEnd()
5226  oprot.trans.flush()
5227 
5228  def process_invalidate_cur_session(self, seqid, iprot, oprot):
5230  args.read(iprot)
5231  iprot.readMessageEnd()
5233  try:
5234  self._handler.invalidate_cur_session(args.parent_session, args.leaf_session, args.start_time_str, args.label, args.for_running_query_kernel)
5235  msg_type = TMessageType.REPLY
5236  except TTransport.TTransportException:
5237  raise
5238  except TOmniSciException as e:
5239  msg_type = TMessageType.REPLY
5240  result.e = e
5241  except TApplicationException as ex:
5242  logging.exception('TApplication exception in handler')
5243  msg_type = TMessageType.EXCEPTION
5244  result = ex
5245  except Exception:
5246  logging.exception('Unexpected exception in handler')
5247  msg_type = TMessageType.EXCEPTION
5248  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5249  oprot.writeMessageBegin("invalidate_cur_session", msg_type, seqid)
5250  result.write(oprot)
5251  oprot.writeMessageEnd()
5252  oprot.trans.flush()
5253 
5254  def process_set_table_epoch(self, seqid, iprot, oprot):
5255  args = set_table_epoch_args()
5256  args.read(iprot)
5257  iprot.readMessageEnd()
5258  result = set_table_epoch_result()
5259  try:
5260  self._handler.set_table_epoch(args.session, args.db_id, args.table_id, args.new_epoch)
5261  msg_type = TMessageType.REPLY
5262  except TTransport.TTransportException:
5263  raise
5264  except TOmniSciException as e:
5265  msg_type = TMessageType.REPLY
5266  result.e = e
5267  except TApplicationException as ex:
5268  logging.exception('TApplication exception in handler')
5269  msg_type = TMessageType.EXCEPTION
5270  result = ex
5271  except Exception:
5272  logging.exception('Unexpected exception in handler')
5273  msg_type = TMessageType.EXCEPTION
5274  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5275  oprot.writeMessageBegin("set_table_epoch", msg_type, seqid)
5276  result.write(oprot)
5277  oprot.writeMessageEnd()
5278  oprot.trans.flush()
5279 
5280  def process_set_table_epoch_by_name(self, seqid, iprot, oprot):
5282  args.read(iprot)
5283  iprot.readMessageEnd()
5285  try:
5286  self._handler.set_table_epoch_by_name(args.session, args.table_name, args.new_epoch)
5287  msg_type = TMessageType.REPLY
5288  except TTransport.TTransportException:
5289  raise
5290  except TOmniSciException as e:
5291  msg_type = TMessageType.REPLY
5292  result.e = e
5293  except TApplicationException as ex:
5294  logging.exception('TApplication exception in handler')
5295  msg_type = TMessageType.EXCEPTION
5296  result = ex
5297  except Exception:
5298  logging.exception('Unexpected exception in handler')
5299  msg_type = TMessageType.EXCEPTION
5300  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5301  oprot.writeMessageBegin("set_table_epoch_by_name", msg_type, seqid)
5302  result.write(oprot)
5303  oprot.writeMessageEnd()
5304  oprot.trans.flush()
5305 
5306  def process_get_table_epoch(self, seqid, iprot, oprot):
5307  args = get_table_epoch_args()
5308  args.read(iprot)
5309  iprot.readMessageEnd()
5310  result = get_table_epoch_result()
5311  try:
5312  result.success = self._handler.get_table_epoch(args.session, args.db_id, args.table_id)
5313  msg_type = TMessageType.REPLY
5314  except TTransport.TTransportException:
5315  raise
5316  except TApplicationException as ex:
5317  logging.exception('TApplication exception in handler')
5318  msg_type = TMessageType.EXCEPTION
5319  result = ex
5320  except Exception:
5321  logging.exception('Unexpected exception in handler')
5322  msg_type = TMessageType.EXCEPTION
5323  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5324  oprot.writeMessageBegin("get_table_epoch", msg_type, seqid)
5325  result.write(oprot)
5326  oprot.writeMessageEnd()
5327  oprot.trans.flush()
5328 
5329  def process_get_table_epoch_by_name(self, seqid, iprot, oprot):
5331  args.read(iprot)
5332  iprot.readMessageEnd()
5334  try:
5335  result.success = self._handler.get_table_epoch_by_name(args.session, args.table_name)
5336  msg_type = TMessageType.REPLY
5337  except TTransport.TTransportException:
5338  raise
5339  except TApplicationException as ex:
5340  logging.exception('TApplication exception in handler')
5341  msg_type = TMessageType.EXCEPTION
5342  result = ex
5343  except Exception:
5344  logging.exception('Unexpected exception in handler')
5345  msg_type = TMessageType.EXCEPTION
5346  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5347  oprot.writeMessageBegin("get_table_epoch_by_name", msg_type, seqid)
5348  result.write(oprot)
5349  oprot.writeMessageEnd()
5350  oprot.trans.flush()
5351 
5352  def process_get_table_epochs(self, seqid, iprot, oprot):
5353  args = get_table_epochs_args()
5354  args.read(iprot)
5355  iprot.readMessageEnd()
5356  result = get_table_epochs_result()
5357  try:
5358  result.success = self._handler.get_table_epochs(args.session, args.db_id, args.table_id)
5359  msg_type = TMessageType.REPLY
5360  except TTransport.TTransportException:
5361  raise
5362  except TApplicationException as ex:
5363  logging.exception('TApplication exception in handler')
5364  msg_type = TMessageType.EXCEPTION
5365  result = ex
5366  except Exception:
5367  logging.exception('Unexpected exception in handler')
5368  msg_type = TMessageType.EXCEPTION
5369  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5370  oprot.writeMessageBegin("get_table_epochs", msg_type, seqid)
5371  result.write(oprot)
5372  oprot.writeMessageEnd()
5373  oprot.trans.flush()
5374 
5375  def process_set_table_epochs(self, seqid, iprot, oprot):
5376  args = set_table_epochs_args()
5377  args.read(iprot)
5378  iprot.readMessageEnd()
5379  result = set_table_epochs_result()
5380  try:
5381  self._handler.set_table_epochs(args.session, args.db_id, args.table_epochs)
5382  msg_type = TMessageType.REPLY
5383  except TTransport.TTransportException:
5384  raise
5385  except TApplicationException as ex:
5386  logging.exception('TApplication exception in handler')
5387  msg_type = TMessageType.EXCEPTION
5388  result = ex
5389  except Exception:
5390  logging.exception('Unexpected exception in handler')
5391  msg_type = TMessageType.EXCEPTION
5392  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5393  oprot.writeMessageBegin("set_table_epochs", msg_type, seqid)
5394  result.write(oprot)
5395  oprot.writeMessageEnd()
5396  oprot.trans.flush()
5397 
5398  def process_get_session_info(self, seqid, iprot, oprot):
5399  args = get_session_info_args()
5400  args.read(iprot)
5401  iprot.readMessageEnd()
5402  result = get_session_info_result()
5403  try:
5404  result.success = self._handler.get_session_info(args.session)
5405  msg_type = TMessageType.REPLY
5406  except TTransport.TTransportException:
5407  raise
5408  except TOmniSciException as e:
5409  msg_type = TMessageType.REPLY
5410  result.e = e
5411  except TApplicationException as ex:
5412  logging.exception('TApplication exception in handler')
5413  msg_type = TMessageType.EXCEPTION
5414  result = ex
5415  except Exception:
5416  logging.exception('Unexpected exception in handler')
5417  msg_type = TMessageType.EXCEPTION
5418  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5419  oprot.writeMessageBegin("get_session_info", msg_type, seqid)
5420  result.write(oprot)
5421  oprot.writeMessageEnd()
5422  oprot.trans.flush()
5423 
5424  def process_sql_execute(self, seqid, iprot, oprot):
5425  args = sql_execute_args()
5426  args.read(iprot)
5427  iprot.readMessageEnd()
5428  result = sql_execute_result()
5429  try:
5430  result.success = self._handler.sql_execute(args.session, args.query, args.column_format, args.nonce, args.first_n, args.at_most_n)
5431  msg_type = TMessageType.REPLY
5432  except TTransport.TTransportException:
5433  raise
5434  except TOmniSciException as e:
5435  msg_type = TMessageType.REPLY
5436  result.e = e
5437  except TApplicationException as ex:
5438  logging.exception('TApplication exception in handler')
5439  msg_type = TMessageType.EXCEPTION
5440  result = ex
5441  except Exception:
5442  logging.exception('Unexpected exception in handler')
5443  msg_type = TMessageType.EXCEPTION
5444  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5445  oprot.writeMessageBegin("sql_execute", msg_type, seqid)
5446  result.write(oprot)
5447  oprot.writeMessageEnd()
5448  oprot.trans.flush()
5449 
5450  def process_sql_execute_df(self, seqid, iprot, oprot):
5451  args = sql_execute_df_args()
5452  args.read(iprot)
5453  iprot.readMessageEnd()
5454  result = sql_execute_df_result()
5455  try:
5456  result.success = self._handler.sql_execute_df(args.session, args.query, args.device_type, args.device_id, args.first_n, args.transport_method)
5457  msg_type = TMessageType.REPLY
5458  except TTransport.TTransportException:
5459  raise
5460  except TOmniSciException as e:
5461  msg_type = TMessageType.REPLY
5462  result.e = e
5463  except TApplicationException as ex:
5464  logging.exception('TApplication exception in handler')
5465  msg_type = TMessageType.EXCEPTION
5466  result = ex
5467  except Exception:
5468  logging.exception('Unexpected exception in handler')
5469  msg_type = TMessageType.EXCEPTION
5470  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5471  oprot.writeMessageBegin("sql_execute_df", msg_type, seqid)
5472  result.write(oprot)
5473  oprot.writeMessageEnd()
5474  oprot.trans.flush()
5475 
5476  def process_sql_execute_gdf(self, seqid, iprot, oprot):
5477  args = sql_execute_gdf_args()
5478  args.read(iprot)
5479  iprot.readMessageEnd()
5480  result = sql_execute_gdf_result()
5481  try:
5482  result.success = self._handler.sql_execute_gdf(args.session, args.query, args.device_id, args.first_n)
5483  msg_type = TMessageType.REPLY
5484  except TTransport.TTransportException:
5485  raise
5486  except TOmniSciException as e:
5487  msg_type = TMessageType.REPLY
5488  result.e = e
5489  except TApplicationException as ex:
5490  logging.exception('TApplication exception in handler')
5491  msg_type = TMessageType.EXCEPTION
5492  result = ex
5493  except Exception:
5494  logging.exception('Unexpected exception in handler')
5495  msg_type = TMessageType.EXCEPTION
5496  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5497  oprot.writeMessageBegin("sql_execute_gdf", msg_type, seqid)
5498  result.write(oprot)
5499  oprot.writeMessageEnd()
5500  oprot.trans.flush()
5501 
5502  def process_deallocate_df(self, seqid, iprot, oprot):
5503  args = deallocate_df_args()
5504  args.read(iprot)
5505  iprot.readMessageEnd()
5506  result = deallocate_df_result()
5507  try:
5508  self._handler.deallocate_df(args.session, args.df, args.device_type, args.device_id)
5509  msg_type = TMessageType.REPLY
5510  except TTransport.TTransportException:
5511  raise
5512  except TOmniSciException as e:
5513  msg_type = TMessageType.REPLY
5514  result.e = e
5515  except TApplicationException as ex:
5516  logging.exception('TApplication exception in handler')
5517  msg_type = TMessageType.EXCEPTION
5518  result = ex
5519  except Exception:
5520  logging.exception('Unexpected exception in handler')
5521  msg_type = TMessageType.EXCEPTION
5522  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5523  oprot.writeMessageBegin("deallocate_df", msg_type, seqid)
5524  result.write(oprot)
5525  oprot.writeMessageEnd()
5526  oprot.trans.flush()
5527 
5528  def process_interrupt(self, seqid, iprot, oprot):
5529  args = interrupt_args()
5530  args.read(iprot)
5531  iprot.readMessageEnd()
5532  result = interrupt_result()
5533  try:
5534  self._handler.interrupt(args.query_session, args.interrupt_session)
5535  msg_type = TMessageType.REPLY
5536  except TTransport.TTransportException:
5537  raise
5538  except TOmniSciException as e:
5539  msg_type = TMessageType.REPLY
5540  result.e = e
5541  except TApplicationException as ex:
5542  logging.exception('TApplication exception in handler')
5543  msg_type = TMessageType.EXCEPTION
5544  result = ex
5545  except Exception:
5546  logging.exception('Unexpected exception in handler')
5547  msg_type = TMessageType.EXCEPTION
5548  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5549  oprot.writeMessageBegin("interrupt", msg_type, seqid)
5550  result.write(oprot)
5551  oprot.writeMessageEnd()
5552  oprot.trans.flush()
5553 
5554  def process_sql_validate(self, seqid, iprot, oprot):
5555  args = sql_validate_args()
5556  args.read(iprot)
5557  iprot.readMessageEnd()
5558  result = sql_validate_result()
5559  try:
5560  result.success = self._handler.sql_validate(args.session, args.query)
5561  msg_type = TMessageType.REPLY
5562  except TTransport.TTransportException:
5563  raise
5564  except TOmniSciException as e:
5565  msg_type = TMessageType.REPLY
5566  result.e = e
5567  except TApplicationException as ex:
5568  logging.exception('TApplication exception in handler')
5569  msg_type = TMessageType.EXCEPTION
5570  result = ex
5571  except Exception:
5572  logging.exception('Unexpected exception in handler')
5573  msg_type = TMessageType.EXCEPTION
5574  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5575  oprot.writeMessageBegin("sql_validate", msg_type, seqid)
5576  result.write(oprot)
5577  oprot.writeMessageEnd()
5578  oprot.trans.flush()
5579 
5580  def process_get_completion_hints(self, seqid, iprot, oprot):
5581  args = get_completion_hints_args()
5582  args.read(iprot)
5583  iprot.readMessageEnd()
5584  result = get_completion_hints_result()
5585  try:
5586  result.success = self._handler.get_completion_hints(args.session, args.sql, args.cursor)
5587  msg_type = TMessageType.REPLY
5588  except TTransport.TTransportException:
5589  raise
5590  except TOmniSciException as e:
5591  msg_type = TMessageType.REPLY
5592  result.e = e
5593  except TApplicationException as ex:
5594  logging.exception('TApplication exception in handler')
5595  msg_type = TMessageType.EXCEPTION
5596  result = ex
5597  except Exception:
5598  logging.exception('Unexpected exception in handler')
5599  msg_type = TMessageType.EXCEPTION
5600  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5601  oprot.writeMessageBegin("get_completion_hints", msg_type, seqid)
5602  result.write(oprot)
5603  oprot.writeMessageEnd()
5604  oprot.trans.flush()
5605 
5606  def process_set_execution_mode(self, seqid, iprot, oprot):
5607  args = set_execution_mode_args()
5608  args.read(iprot)
5609  iprot.readMessageEnd()
5610  result = set_execution_mode_result()
5611  try:
5612  self._handler.set_execution_mode(args.session, args.mode)
5613  msg_type = TMessageType.REPLY
5614  except TTransport.TTransportException:
5615  raise
5616  except TOmniSciException as e:
5617  msg_type = TMessageType.REPLY
5618  result.e = e
5619  except TApplicationException as ex:
5620  logging.exception('TApplication exception in handler')
5621  msg_type = TMessageType.EXCEPTION
5622  result = ex
5623  except Exception:
5624  logging.exception('Unexpected exception in handler')
5625  msg_type = TMessageType.EXCEPTION
5626  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5627  oprot.writeMessageBegin("set_execution_mode", msg_type, seqid)
5628  result.write(oprot)
5629  oprot.writeMessageEnd()
5630  oprot.trans.flush()
5631 
5632  def process_render_vega(self, seqid, iprot, oprot):
5633  args = render_vega_args()
5634  args.read(iprot)
5635  iprot.readMessageEnd()
5636  result = render_vega_result()
5637  try:
5638  result.success = self._handler.render_vega(args.session, args.widget_id, args.vega_json, args.compression_level, args.nonce)
5639  msg_type = TMessageType.REPLY
5640  except TTransport.TTransportException:
5641  raise
5642  except TOmniSciException as e:
5643  msg_type = TMessageType.REPLY
5644  result.e = e
5645  except TApplicationException as ex:
5646  logging.exception('TApplication exception in handler')
5647  msg_type = TMessageType.EXCEPTION
5648  result = ex
5649  except Exception:
5650  logging.exception('Unexpected exception in handler')
5651  msg_type = TMessageType.EXCEPTION
5652  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5653  oprot.writeMessageBegin("render_vega", msg_type, seqid)
5654  result.write(oprot)
5655  oprot.writeMessageEnd()
5656  oprot.trans.flush()
5657 
5658  def process_get_result_row_for_pixel(self, seqid, iprot, oprot):
5660  args.read(iprot)
5661  iprot.readMessageEnd()
5663  try:
5664  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)
5665  msg_type = TMessageType.REPLY
5666  except TTransport.TTransportException:
5667  raise
5668  except TOmniSciException as e:
5669  msg_type = TMessageType.REPLY
5670  result.e = e
5671  except TApplicationException as ex:
5672  logging.exception('TApplication exception in handler')
5673  msg_type = TMessageType.EXCEPTION
5674  result = ex
5675  except Exception:
5676  logging.exception('Unexpected exception in handler')
5677  msg_type = TMessageType.EXCEPTION
5678  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5679  oprot.writeMessageBegin("get_result_row_for_pixel", msg_type, seqid)
5680  result.write(oprot)
5681  oprot.writeMessageEnd()
5682  oprot.trans.flush()
5683 
5684  def process_create_custom_expression(self, seqid, iprot, oprot):
5686  args.read(iprot)
5687  iprot.readMessageEnd()
5689  try:
5690  result.success = self._handler.create_custom_expression(args.session, args.custom_expression)
5691  msg_type = TMessageType.REPLY
5692  except TTransport.TTransportException:
5693  raise
5694  except TOmniSciException as e:
5695  msg_type = TMessageType.REPLY
5696  result.e = e
5697  except TApplicationException as ex:
5698  logging.exception('TApplication exception in handler')
5699  msg_type = TMessageType.EXCEPTION
5700  result = ex
5701  except Exception:
5702  logging.exception('Unexpected exception in handler')
5703  msg_type = TMessageType.EXCEPTION
5704  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5705  oprot.writeMessageBegin("create_custom_expression", msg_type, seqid)
5706  result.write(oprot)
5707  oprot.writeMessageEnd()
5708  oprot.trans.flush()
5709 
5710  def process_get_custom_expressions(self, seqid, iprot, oprot):
5712  args.read(iprot)
5713  iprot.readMessageEnd()
5715  try:
5716  result.success = self._handler.get_custom_expressions(args.session)
5717  msg_type = TMessageType.REPLY
5718  except TTransport.TTransportException:
5719  raise
5720  except TOmniSciException as e:
5721  msg_type = TMessageType.REPLY
5722  result.e = e
5723  except TApplicationException as ex:
5724  logging.exception('TApplication exception in handler')
5725  msg_type = TMessageType.EXCEPTION
5726  result = ex
5727  except Exception:
5728  logging.exception('Unexpected exception in handler')
5729  msg_type = TMessageType.EXCEPTION
5730  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5731  oprot.writeMessageBegin("get_custom_expressions", msg_type, seqid)
5732  result.write(oprot)
5733  oprot.writeMessageEnd()
5734  oprot.trans.flush()
5735 
5736  def process_update_custom_expression(self, seqid, iprot, oprot):
5738  args.read(iprot)
5739  iprot.readMessageEnd()
5741  try:
5742  self._handler.update_custom_expression(args.session, args.id, args.expression_json)
5743  msg_type = TMessageType.REPLY
5744  except TTransport.TTransportException:
5745  raise
5746  except TOmniSciException as e:
5747  msg_type = TMessageType.REPLY
5748  result.e = e
5749  except TApplicationException as ex:
5750  logging.exception('TApplication exception in handler')
5751  msg_type = TMessageType.EXCEPTION
5752  result = ex
5753  except Exception:
5754  logging.exception('Unexpected exception in handler')
5755  msg_type = TMessageType.EXCEPTION
5756  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5757  oprot.writeMessageBegin("update_custom_expression", msg_type, seqid)
5758  result.write(oprot)
5759  oprot.writeMessageEnd()
5760  oprot.trans.flush()
5761 
5762  def process_delete_custom_expressions(self, seqid, iprot, oprot):
5764  args.read(iprot)
5765  iprot.readMessageEnd()
5767  try:
5768  self._handler.delete_custom_expressions(args.session, args.custom_expression_ids, args.do_soft_delete)
5769  msg_type = TMessageType.REPLY
5770  except TTransport.TTransportException:
5771  raise
5772  except TOmniSciException as e:
5773  msg_type = TMessageType.REPLY
5774  result.e = e
5775  except TApplicationException as ex:
5776  logging.exception('TApplication exception in handler')
5777  msg_type = TMessageType.EXCEPTION
5778  result = ex
5779  except Exception:
5780  logging.exception('Unexpected exception in handler')
5781  msg_type = TMessageType.EXCEPTION
5782  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5783  oprot.writeMessageBegin("delete_custom_expressions", msg_type, seqid)
5784  result.write(oprot)
5785  oprot.writeMessageEnd()
5786  oprot.trans.flush()
5787 
5788  def process_get_dashboard(self, seqid, iprot, oprot):
5789  args = get_dashboard_args()
5790  args.read(iprot)
5791  iprot.readMessageEnd()
5792  result = get_dashboard_result()
5793  try:
5794  result.success = self._handler.get_dashboard(args.session, args.dashboard_id)
5795  msg_type = TMessageType.REPLY
5796  except TTransport.TTransportException:
5797  raise
5798  except TOmniSciException as e:
5799  msg_type = TMessageType.REPLY
5800  result.e = e
5801  except TApplicationException as ex:
5802  logging.exception('TApplication exception in handler')
5803  msg_type = TMessageType.EXCEPTION
5804  result = ex
5805  except Exception:
5806  logging.exception('Unexpected exception in handler')
5807  msg_type = TMessageType.EXCEPTION
5808  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5809  oprot.writeMessageBegin("get_dashboard", msg_type, seqid)
5810  result.write(oprot)
5811  oprot.writeMessageEnd()
5812  oprot.trans.flush()
5813 
5814  def process_get_dashboards(self, seqid, iprot, oprot):
5815  args = get_dashboards_args()
5816  args.read(iprot)
5817  iprot.readMessageEnd()
5818  result = get_dashboards_result()
5819  try:
5820  result.success = self._handler.get_dashboards(args.session)
5821  msg_type = TMessageType.REPLY
5822  except TTransport.TTransportException:
5823  raise
5824  except TOmniSciException as e:
5825  msg_type = TMessageType.REPLY
5826  result.e = e
5827  except TApplicationException as ex:
5828  logging.exception('TApplication exception in handler')
5829  msg_type = TMessageType.EXCEPTION
5830  result = ex
5831  except Exception:
5832  logging.exception('Unexpected exception in handler')
5833  msg_type = TMessageType.EXCEPTION
5834  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5835  oprot.writeMessageBegin("get_dashboards", msg_type, seqid)
5836  result.write(oprot)
5837  oprot.writeMessageEnd()
5838  oprot.trans.flush()
5839 
5840  def process_create_dashboard(self, seqid, iprot, oprot):
5841  args = create_dashboard_args()
5842  args.read(iprot)
5843  iprot.readMessageEnd()
5844  result = create_dashboard_result()
5845  try:
5846  result.success = self._handler.create_dashboard(args.session, args.dashboard_name, args.dashboard_state, args.image_hash, args.dashboard_metadata)
5847  msg_type = TMessageType.REPLY
5848  except TTransport.TTransportException:
5849  raise
5850  except TOmniSciException as e:
5851  msg_type = TMessageType.REPLY
5852  result.e = e
5853  except TApplicationException as ex:
5854  logging.exception('TApplication exception in handler')
5855  msg_type = TMessageType.EXCEPTION
5856  result = ex
5857  except Exception:
5858  logging.exception('Unexpected exception in handler')
5859  msg_type = TMessageType.EXCEPTION
5860  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5861  oprot.writeMessageBegin("create_dashboard", msg_type, seqid)
5862  result.write(oprot)
5863  oprot.writeMessageEnd()
5864  oprot.trans.flush()
5865 
5866  def process_replace_dashboard(self, seqid, iprot, oprot):
5867  args = replace_dashboard_args()
5868  args.read(iprot)
5869  iprot.readMessageEnd()
5870  result = replace_dashboard_result()
5871  try:
5872  self._handler.replace_dashboard(args.session, args.dashboard_id, args.dashboard_name, args.dashboard_owner, args.dashboard_state, args.image_hash, args.dashboard_metadata)
5873  msg_type = TMessageType.REPLY
5874  except TTransport.TTransportException:
5875  raise
5876  except TOmniSciException as e:
5877  msg_type = TMessageType.REPLY
5878  result.e = e
5879  except TApplicationException as ex:
5880  logging.exception('TApplication exception in handler')
5881  msg_type = TMessageType.EXCEPTION
5882  result = ex
5883  except Exception:
5884  logging.exception('Unexpected exception in handler')
5885  msg_type = TMessageType.EXCEPTION
5886  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5887  oprot.writeMessageBegin("replace_dashboard", msg_type, seqid)
5888  result.write(oprot)
5889  oprot.writeMessageEnd()
5890  oprot.trans.flush()
5891 
5892  def process_delete_dashboard(self, seqid, iprot, oprot):
5893  args = delete_dashboard_args()
5894  args.read(iprot)
5895  iprot.readMessageEnd()
5896  result = delete_dashboard_result()
5897  try:
5898  self._handler.delete_dashboard(args.session, args.dashboard_id)
5899  msg_type = TMessageType.REPLY
5900  except TTransport.TTransportException:
5901  raise
5902  except TOmniSciException as e:
5903  msg_type = TMessageType.REPLY
5904  result.e = e
5905  except TApplicationException as ex:
5906  logging.exception('TApplication exception in handler')
5907  msg_type = TMessageType.EXCEPTION
5908  result = ex
5909  except Exception:
5910  logging.exception('Unexpected exception in handler')
5911  msg_type = TMessageType.EXCEPTION
5912  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5913  oprot.writeMessageBegin("delete_dashboard", msg_type, seqid)
5914  result.write(oprot)
5915  oprot.writeMessageEnd()
5916  oprot.trans.flush()
5917 
5918  def process_share_dashboards(self, seqid, iprot, oprot):
5919  args = share_dashboards_args()
5920  args.read(iprot)
5921  iprot.readMessageEnd()
5922  result = share_dashboards_result()
5923  try:
5924  self._handler.share_dashboards(args.session, args.dashboard_ids, args.groups, args.permissions)
5925  msg_type = TMessageType.REPLY
5926  except TTransport.TTransportException:
5927  raise
5928  except TOmniSciException as e:
5929  msg_type = TMessageType.REPLY
5930  result.e = e
5931  except TApplicationException as ex:
5932  logging.exception('TApplication exception in handler')
5933  msg_type = TMessageType.EXCEPTION
5934  result = ex
5935  except Exception:
5936  logging.exception('Unexpected exception in handler')
5937  msg_type = TMessageType.EXCEPTION
5938  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5939  oprot.writeMessageBegin("share_dashboards", msg_type, seqid)
5940  result.write(oprot)
5941  oprot.writeMessageEnd()
5942  oprot.trans.flush()
5943 
5944  def process_delete_dashboards(self, seqid, iprot, oprot):
5945  args = delete_dashboards_args()
5946  args.read(iprot)
5947  iprot.readMessageEnd()
5948  result = delete_dashboards_result()
5949  try:
5950  self._handler.delete_dashboards(args.session, args.dashboard_ids)
5951  msg_type = TMessageType.REPLY
5952  except TTransport.TTransportException:
5953  raise
5954  except TOmniSciException as e:
5955  msg_type = TMessageType.REPLY
5956  result.e = e
5957  except TApplicationException as ex:
5958  logging.exception('TApplication exception in handler')
5959  msg_type = TMessageType.EXCEPTION
5960  result = ex
5961  except Exception:
5962  logging.exception('Unexpected exception in handler')
5963  msg_type = TMessageType.EXCEPTION
5964  result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
5965  oprot.writeMessageBegin("delete_dashboards", msg_type, seqid)
5966  result.write(oprot)
5967  oprot.writeMessageEnd()
5968  oprot.trans.flush()
5969 
5970  def process_share_dashboard(self, seqid, iprot, oprot):
5971  args = share_dashboard_args()
5972  args.read(iprot)
5973  iprot.readMessageEnd()
5974  result = share_dashboard_result()
5975  try:
5976  self._handler.share_dashboard(args.session, args.dashboard_id, args.groups, args.objects, args.permissions, args.grant_role)
5977  msg_type = TMessageType.REPLY
5978  except TTransport.TTransportException:
5979  raise
5980