def METHOD_NAME(**queries: Dict[str, STORE_PARAMS]) -> Dict:
    request: Request = queries.pop("request")  # type: ignore
    temp_response: Response = queries.pop("temp_response")  # type: ignore
    query: Dict[Any, Any] = merge_queries(list(queries.values()))  # type: ignore
    self.store.connect()
    try:
        with query_timeout(self.timeout):
            data = list(self.store._collection.aggregate(query["pipeline"]))
    except (NetworkTimeout, PyMongoError) as e:
        if e.timeout:
            raise HTTPException(
                status_code=504,
                detail="Server timed out trying to obtain data. Try again with a smaller request.",
            )
        else:
            raise HTTPException(
                status_code=500,
            )
    count = len(data)
    data = self.pipeline_query_operator.post_process(data, query)
    operator_meta = self.pipeline_query_operator.meta()
    meta = Meta(total_doc=count)
    response = {"data": data, "meta": {**meta.dict(), **operator_meta}}
    if self.header_processor is not None:
        self.header_processor.process_header(temp_response, request)
    return response