(self)
| 2693 | return trigger_meta |
| 2694 | |
| 2695 | def _query_all(self): |
| 2696 | cl = ConsistencyLevel.ONE |
| 2697 | queries = [ |
| 2698 | QueryMessage(query=self._SELECT_KEYSPACES, consistency_level=cl), |
| 2699 | QueryMessage(query=self._SELECT_TABLES, consistency_level=cl), |
| 2700 | QueryMessage(query=self._SELECT_COLUMNS, consistency_level=cl), |
| 2701 | QueryMessage(query=self._SELECT_TYPES, consistency_level=cl), |
| 2702 | QueryMessage(query=self._SELECT_FUNCTIONS, consistency_level=cl), |
| 2703 | QueryMessage(query=self._SELECT_AGGREGATES, consistency_level=cl), |
| 2704 | QueryMessage(query=self._SELECT_TRIGGERS, consistency_level=cl), |
| 2705 | QueryMessage(query=self._SELECT_INDEXES, consistency_level=cl), |
| 2706 | QueryMessage(query=self._SELECT_VIEWS, consistency_level=cl) |
| 2707 | ] |
| 2708 | |
| 2709 | ((ks_success, ks_result), |
| 2710 | (table_success, table_result), |
| 2711 | (col_success, col_result), |
| 2712 | (types_success, types_result), |
| 2713 | (functions_success, functions_result), |
| 2714 | (aggregates_success, aggregates_result), |
| 2715 | (triggers_success, triggers_result), |
| 2716 | (indexes_success, indexes_result), |
| 2717 | (views_success, views_result)) = self.connection.wait_for_responses( |
| 2718 | *queries, timeout=self.timeout, fail_on_error=False |
| 2719 | ) |
| 2720 | |
| 2721 | self.keyspaces_result = self._handle_results(ks_success, ks_result) |
| 2722 | self.tables_result = self._handle_results(table_success, table_result) |
| 2723 | self.columns_result = self._handle_results(col_success, col_result) |
| 2724 | self.triggers_result = self._handle_results(triggers_success, triggers_result) |
| 2725 | self.types_result = self._handle_results(types_success, types_result) |
| 2726 | self.functions_result = self._handle_results(functions_success, functions_result) |
| 2727 | self.aggregates_result = self._handle_results(aggregates_success, aggregates_result) |
| 2728 | self.indexes_result = self._handle_results(indexes_success, indexes_result) |
| 2729 | self.views_result = self._handle_results(views_success, views_result) |
| 2730 | |
| 2731 | self._aggregate_results() |
| 2732 | |
| 2733 | def _aggregate_results(self): |
| 2734 | super(SchemaParserV3, self)._aggregate_results() |
nothing calls this directly
no test coverage detected