(self)
| 525 | ) |
| 526 | |
| 527 | def _check_connection_ok(self) -> None: |
| 528 | if self.pgconn.status == OK: |
| 529 | return |
| 530 | |
| 531 | if self.pgconn.status == BAD: |
| 532 | raise e.OperationalError("the connection is closed") |
| 533 | raise e.InterfaceError( |
| 534 | "cannot execute operations: the connection is" |
| 535 | f" in status {self.pgconn.status}" |
| 536 | ) |
| 537 | |
| 538 | def _start_query(self) -> PQGen[None]: |
| 539 | """Generator to start a transaction if necessary.""" |
no outgoing calls
no test coverage detected