| 112 | self.query_id = None |
| 113 | |
| 114 | def execute_async(self): |
| 115 | # change database. |
| 116 | use_handle = self.client.execute_async('use ' + self.db_name) |
| 117 | self.client.wait_for(use_handle) |
| 118 | self.client.close_query(use_handle) |
| 119 | self.client.set_configuration(self.exec_option) |
| 120 | # execute the query. |
| 121 | self.handle = self.client.execute_async(self.query) |
| 122 | self.is_error = self.client.get_impala_exec_state(self.handle) == ERROR |
| 123 | self.query_id = self.client.handle_id(self.handle) |
| 124 | |
| 125 | def run(self): |
| 126 | if self.is_error: |