Method _abort

asyncpg/connection.py:1573–1577

(self)

                await self.execute(reset_query)

    def _abort(self):
        # Put the connection into the aborted state.
        self._aborted = True
        self._protocol.abort()
        self._protocol = None

    def _cleanup(self):
        self._call_termination_listeners()