async def get_sync_job(
        self,
        db: AsyncSession,
        job_id: UUID,
        current_user: schemas.User,
        sync_id: Optional[UUID] = None,
    ) -> schemas.SyncJob:
        """Get a specific sync job.

        Args:
        ----
            db (AsyncSession): The database session.
            job_id (UUID): The ID of the job to get.
            current_user (schemas.User): The current user.
            sync_id (Optional[UUID]): The sync ID for validation.

        Returns:
        -------
            schemas.SyncJob: The sync job.

        Raises:
        ------
            HTTPException: If the job is not found or doesn't match the sync.
        """
        sync_job = await crud.sync_job.get(db=db, id=job_id, current_user=current_user)
        if not sync_job or (sync_id and sync_job.sync_id != sync_id):
            raise HTTPException(status_code=404, detail="Sync job not found")
        return sync_job
Get a specific sync job.

        Args:
        ----
            db (AsyncSession): The database session.
            job_id (UUID): The ID of the job to get.
            current_user (schemas.User): The current user.
            sync_id (Optional[UUID]): The sync ID for validation.

        Returns:
        -------
            schemas.SyncJob: The sync job.

        Raises:
        ------
            HTTPException: If the job is not found or doesn't match the sync.
        
backend/airweave/core/sync_service.py