(self, sql_stmt)
| 1041 | raise NotImplementedError() |
| 1042 | |
| 1043 | def execute_async(self, sql_stmt): |
| 1044 | self.__log_execute(sql_stmt) |
| 1045 | hs2_operation = self.__session.execute(sql_stmt, configuration=self.__query_options) |
| 1046 | operation_handle = MinimalHS2OperationHandle(hs2_operation.handle, sql_stmt) |
| 1047 | self.log_handle(operation_handle, "query started") |
| 1048 | return operation_handle |
| 1049 | |
| 1050 | def __get_operation(self, operation_handle): |
| 1051 | return hs2.Operation(self.__session, operation_handle.get_handle()) |