async def get_connection(
        self, db: AsyncSession, connection_id: UUID, user: schemas.User
    ) -> schemas.Connection:
        """Get a specific connection by ID.

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

        Returns:
            The connection

        Raises:
            NotFoundException: If the connection is not found
        """
        connection = await crud.connection.get(db, id=connection_id, current_user=user)
        if not connection:
            raise NotFoundException("Connection not found")
        return connection
Get a specific connection by ID.

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

        Returns:
            The connection

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