def METHOD_NAME(self, record: AirbyteRecordMessage) -> Tuple[List[Document], Optional[str]]:
    """
    Generate documents from records.
    :param records: List of AirbyteRecordMessages
    :return: Tuple of (List of document chunks, record id to delete if a stream is in dedup mode to avoid stale documents in the vector store)
    """
    doc = self._generate_document(record)
    if doc is None:
        self.logger.warning(f"Record {str(record.data)[:250]}... does not contain any text fields. Skipping.")
        return [], None
    chunks = self._split_document(doc)
    id_to_delete = doc.metadata[METADATA_RECORD_ID_FIELD] if METADATA_RECORD_ID_FIELD in doc.metadata else None
    return chunks, id_to_delete