def METHOD_NAME(
    self,
    pipeline_name: str,
    job_name: JobId,
) -> Optional[DatahubIngestionCheckpointClass]:
    logger.debug(
        f"Querying for the latest ingestion checkpoint for pipelineName:'{pipeline_name}',"
        f" job_name:'{job_name}'"
    )
    data_job_urn = self.get_data_job_urn(
        self.orchestrator_name, pipeline_name, job_name
    )
    latest_checkpoint: Optional[
        DatahubIngestionCheckpointClass
    ] = self.graph.get_latest_timeseries_value(
        entity_urn=data_job_urn,
        aspect_type=DatahubIngestionCheckpointClass,
        filter_criteria_map={
            "pipelineName": pipeline_name,
        },
    )
    if latest_checkpoint:
        logger.debug(
            f"The last committed ingestion checkpoint for pipelineName:'{pipeline_name}',"
            f" job_name:'{job_name}' found with start_time:"
            f" {datetime.utcfromtimestamp(latest_checkpoint.timestampMillis/1000)}"
        )
        return latest_checkpoint
    else:
        logger.debug(
            f"No committed ingestion checkpoint for pipelineName:'{pipeline_name}',"
            f" job_name:'{job_name}' found"
        )
    return None