async def _get_and_validate_sync(
        self, db: AsyncSession, sync_id: UUID, current_user: schemas.User
    ) -> schemas.Sync:
        """Get and validate that the sync exists.

        Args:
        ----
            db (AsyncSession): The database session.
            sync_id (UUID): The ID of the sync to get.
            current_user (schemas.User): The current user.

        Returns:
        -------
            schemas.Sync: The sync.

        Raises:
        ------
            Exception: If the sync is not found.
        """
        sync = await crud.sync.get(db, id=sync_id, current_user=current_user, with_connections=True)
        if not sync:
            raise Exception(f"Sync for {sync_id} not found")
        return sync
Get and validate that the sync exists.

        Args:
        ----
            db (AsyncSession): The database session.
            sync_id (UUID): The ID of the sync to get.
            current_user (schemas.User): The current user.

        Returns:
        -------
            schemas.Sync: The sync.

        Raises:
        ------
            Exception: If the sync is not found.
        
backend/airweave/core/dag_service.py