(self)
| 228 | assert not self.pinned_txn |
| 229 | |
| 230 | async def unpin(self) -> None: |
| 231 | pool = self.pool_ref() |
| 232 | if pool: |
| 233 | await pool.checkin(self) |
| 234 | else: |
| 235 | await self.close_conn(ConnectionClosedReason.STALE) |
| 236 | |
| 237 | def hello_cmd(self) -> dict[str, Any]: |
| 238 | # Handshake spec requires us to use OP_MSG+hello command for the |
no test coverage detected