(self, proxy)
| 1759 | return _reset_query |
| 1760 | |
| 1761 | def _set_proxy(self, proxy): |
| 1762 | if self._proxy is not None and proxy is not None: |
| 1763 | # Should not happen unless there is a bug in `Pool`. |
| 1764 | raise exceptions.InterfaceError( |
| 1765 | 'internal asyncpg error: connection is already proxied') |
| 1766 | |
| 1767 | self._proxy = proxy |
| 1768 | |
| 1769 | def _check_listeners(self, listeners, listener_type): |
| 1770 | if listeners: |