async def _ensure_pool(self) -> asyncpg.Pool:
        """Ensure connection pool is initialized and return it."""
        if not self.pool:
            username = self._get_credential("username")
            password = self._get_credential("password")

            # Use the shared connection pool
            self.pool = await get_ctti_pool(username, password)

        return self.pool
Ensure connection pool is initialized and return it.
backend/airweave/platform/sources/ctti.py