async def _generate_balance_entity(
        self, client: httpx.AsyncClient
    ) -> AsyncGenerator[ChunkEntity, None]:
        """Retrieve the current account balance (single object) from.

        GET https://api.stripe.com/v1/balance
        Yields exactly one StripeBalanceEntity if successful.
        """
        url = "https://api.stripe.com/v1/balance"
        data = await self._get_with_auth(client, url)

        # Create the entity with the raw data structures from Stripe
        # This avoids any issues with nested dictionaries like source_types
        # We don't manually extract nested fields but pass them directly as they are
        yield StripeBalanceEntity(
            entity_id="balance",  # Arbitrary ID since there's only one balance resource
            available=data.get("available", []),
            pending=data.get("pending", []),
            instant_available=data.get("instant_available"),
            connect_reserved=data.get("connect_reserved"),
            livemode=data.get("livemode", False),
        )
Retrieve the current account balance (single object) from.

        GET https://api.stripe.com/v1/balance
        Yields exactly one StripeBalanceEntity if successful.
        
backend/airweave/platform/sources/stripe.py