(self, *, timeout: float = 5.0)
| 336 | self.cancel() |
| 337 | |
| 338 | def _try_cancel(self, *, timeout: float = 5.0) -> None: |
| 339 | try: |
| 340 | self.cancel_safe(timeout=timeout) |
| 341 | except Exception as ex: |
| 342 | logger.warning("query cancellation failed: %s", ex) |
| 343 | |
| 344 | @contextmanager |
| 345 | def transaction( |