| 971 | |
| 972 | |
| 973 | class AddConnection(MaintenanceTask): |
| 974 | |
| 975 | def __init__( |
| 976 | self, |
| 977 | pool: ConnectionPool[Any], |
| 978 | attempt: AttemptWithBackoff | None = None, |
| 979 | growing: bool = False, |
| 980 | ): |
| 981 | super().__init__(pool) |
| 982 | self.attempt = attempt |
| 983 | self.growing = growing |
| 984 | |
| 985 | def _run(self, pool: ConnectionPool[Any]) -> None: |
| 986 | pool._add_connection(self.attempt, growing=self.growing) |
| 987 | |
| 988 | |
| 989 | class ReturnConnection(MaintenanceTask): |
no outgoing calls
no test coverage detected