(self)
| 3764 | return None |
| 3765 | |
| 3766 | def shutdown(self): |
| 3767 | # stop trying to reconnect (if we are) |
| 3768 | with self._reconnection_lock: |
| 3769 | if self._reconnection_handler: |
| 3770 | self._reconnection_handler.cancel() |
| 3771 | |
| 3772 | with self._lock: |
| 3773 | if self._is_shutdown: |
| 3774 | return |
| 3775 | else: |
| 3776 | self._is_shutdown = True |
| 3777 | |
| 3778 | log.debug("Shutting down control connection") |
| 3779 | if self._connection: |
| 3780 | self._connection.close() |
| 3781 | self._connection = None |
| 3782 | |
| 3783 | def refresh_schema(self, force=False, **kwargs): |
| 3784 | try: |