async def get_source_connection_job(
        self,
        db: AsyncSession,
        source_connection_id: UUID,
        job_id: UUID,
        current_user: schemas.User,
    ) -> schemas.SourceConnectionJob:
        """Get a specific sync job for a source connection.

        Args:
            db: The database session
            source_connection_id: The ID of the source connection
            job_id: The ID of the sync job
            current_user: The current user

        Returns:
            The sync job

        Raises:
            HTTPException: If the source connection or job is not found
        """
        source_connection = await crud.source_connection.get(
            db=db, id=source_connection_id, current_user=current_user
        )
        if not source_connection:
            raise HTTPException(status_code=404, detail="Source connection not found")

        if not source_connection.sync_id:
            raise HTTPException(status_code=404, detail="Source connection has no associated sync")

        # Get the specific job for the sync
        sync_job = await sync_service.get_sync_job(
            db=db, job_id=job_id, current_user=current_user, sync_id=source_connection.sync_id
        )

        sync_job_schema = schemas.SyncJob.model_validate(sync_job, from_attributes=True)

        # Convert to SourceConnectionJob format
        source_connection_job = sync_job_schema.to_source_connection_job(source_connection_id)

        return source_connection_job
Get a specific sync job for a source connection.

        Args:
            db: The database session
            source_connection_id: The ID of the source connection
            job_id: The ID of the sync job
            current_user: The current user

        Returns:
            The sync job

        Raises:
            HTTPException: If the source connection or job is not found
        
backend/airweave/core/source_connection_service.py