async def get_connection_credentials(
        self, db: AsyncSession, connection_id: UUID, user: schemas.User
    ) -> Dict[str, Any]:
        """Get decrypted credentials for a connection.

        Args:
            db: The database session
            connection_id: The ID of the connection
            user: The current user

        Returns:
            The decrypted credentials

        Raises:
            NotFoundException: If the connection or credential is not found
        """
        connection = await crud.connection.get(db, id=connection_id, current_user=user)
        if not connection:
            raise NotFoundException("Connection not found")

        if not connection.integration_credential_id:
            raise NotFoundException("Connection has no integration credential")

        integration_credential = await crud.integration_credential.get(
            db, id=connection.integration_credential_id, current_user=user
        )

        if not integration_credential:
            raise NotFoundException("Integration credential not found")

        return credentials.decrypt(integration_credential.encrypted_credentials)
Get decrypted credentials for a connection.

        Args:
            db: The database session
            connection_id: The ID of the connection
            user: The current user

        Returns:
            The decrypted credentials

        Raises:
            NotFoundException: If the connection or credential is not found
        
backend/airweave/core/connection_service.py