from src.utils.log import get_logger logger = get_logger() class ESRetriever(Retriever): def __init__(self, data_set): pass def retrieve(self, query: str, k: int): pass