(self, conn: CT, from_getconn: bool)
| 352 | self.run_task(AddConnection(self)) |
| 353 | |
| 354 | def _putconn(self, conn: CT, from_getconn: bool) -> None: |
| 355 | # Use a worker to perform eventual maintenance work in a separate task |
| 356 | if self._reset: |
| 357 | self.run_task(ReturnConnection(self, conn, from_getconn=from_getconn)) |
| 358 | else: |
| 359 | self._return_connection(conn, from_getconn=from_getconn) |
| 360 | |
| 361 | def _maybe_close_connection(self, conn: CT) -> bool: |
| 362 | """Close a returned connection if necessary. |
no test coverage detected