async def get_sync_dag(
        self,
        db: AsyncSession,
        sync_id: UUID,
        current_user: schemas.User,
    ) -> schemas.SyncDag:
        """Get the DAG for a specific sync.

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

        Returns:
        -------
            schemas.SyncDag: The sync DAG.

        Raises:
        ------
            HTTPException: If the DAG is not found.
        """
        dag = await crud.sync_dag.get_by_sync_id(db=db, sync_id=sync_id, current_user=current_user)
        if not dag:
            raise HTTPException(status_code=404, detail=f"DAG for sync {sync_id} not found")
        return dag
Get the DAG for a specific sync.

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

        Returns:
        -------
            schemas.SyncDag: The sync DAG.

        Raises:
        ------
            HTTPException: If the DAG is not found.
        
backend/airweave/core/sync_service.py