Method _putconn

psycopg_pool/psycopg_pool/pool_async.py:392–397

(self, conn: ACT, from_getconn: bool)

            self.run_task(AddConnection(self))

    async def _putconn(self, conn: ACT, from_getconn: bool) -> None:
        # Use a worker to perform eventual maintenance work in a separate task
        if self._reset:
            self.run_task(ReturnConnection(self, conn, from_getconn=from_getconn))
        else:
            await self._return_connection(conn, from_getconn=from_getconn)

    async def _maybe_close_connection(self, conn: ACT) -> bool:
        """Close a returned connection if necessary.