def pubsub_client(self) -> redis.Redis:
        """Get or create the pubsub Redis client for SSE."""
        if self._pubsub_client is None:
            self._pubsub_client = self._create_client(max_connections=100)
        return self._pubsub_client
Get or create the pubsub Redis client for SSE.
backend/airweave/core/redis_client.py