(self, connection, preloaded_results=None, schema_agreement_wait=None, force=False, **kwargs)
| 3792 | return False |
| 3793 | |
| 3794 | def _refresh_schema(self, connection, preloaded_results=None, schema_agreement_wait=None, force=False, **kwargs): |
| 3795 | if self._cluster.is_shutdown: |
| 3796 | return False |
| 3797 | |
| 3798 | agreed = self.wait_for_schema_agreement(connection, |
| 3799 | preloaded_results=preloaded_results, |
| 3800 | wait_time=schema_agreement_wait) |
| 3801 | |
| 3802 | if not self._schema_meta_enabled and not force: |
| 3803 | log.debug("[control connection] Skipping schema refresh because schema metadata is disabled") |
| 3804 | return False |
| 3805 | |
| 3806 | if not agreed: |
| 3807 | log.debug("Skipping schema refresh due to lack of schema agreement") |
| 3808 | return False |
| 3809 | |
| 3810 | self._cluster.metadata.refresh(connection, self._timeout, **kwargs) |
| 3811 | |
| 3812 | return True |
| 3813 | |
| 3814 | def refresh_node_list_and_token_map(self, force_token_rebuild=False): |
| 3815 | try: |
no test coverage detected