(self, client_args: ClientArgs)
| 205 | |
| 206 | class PQPool(Pool): |
| 207 | def __init__(self, client_args: ClientArgs) -> None: |
| 208 | super().__init__(client_args) # unlimited size |
| 209 | |
| 210 | # Initialize the heap with resources |
| 211 | heapify(self.queue) |
| 212 | |
| 213 | def __enter__(self, **kwargs) -> ClientArgs: |
| 214 | """Get a client from the pool and return it as a context manager.""" |