| 3781 | self._connection = None |
| 3782 | |
| 3783 | def refresh_schema(self, force=False, **kwargs): |
| 3784 | try: |
| 3785 | if self._connection: |
| 3786 | return self._refresh_schema(self._connection, force=force, **kwargs) |
| 3787 | except ReferenceError: |
| 3788 | pass # our weak reference to the Cluster is no good |
| 3789 | except Exception: |
| 3790 | log.debug("[control connection] Error refreshing schema", exc_info=True) |
| 3791 | self._signal_error() |
| 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: |