diff --git a/redis/commands/search/aggregation.py b/redis/commands/search/aggregation.py index 50d18f476a..e55265fbd8 100644 --- a/redis/commands/search/aggregation.py +++ b/redis/commands/search/aggregation.py @@ -321,7 +321,10 @@ def build_args(self) -> List[str]: if self._loadall: ret.append("LOAD") ret.append("*") - elif self._loadfields: + + # NOTE(imalinovskyi): Users should be able to use @__key attribute + # in wildcard queries + if self._loadfields: ret.append("LOAD") ret.append(str(len(self._loadfields))) ret.extend(self._loadfields)