def METHOD_NAME(self, query: str) -> pd.DataFrame:
    iter_data_files = (
        tqdm(self.data_files[query]) if self._progress else self.data_files[query]
    )
    dfs = [pd.read_json(file, lines=True) for file in iter_data_files]
    query_df = pd.concat(dfs, ignore_index=True)
    logger.info("Query %s, returned %d rows", query, len(query_df))
    return query_df