Skip to content

Commit 5fa7a4d

Browse files
authored
Fix ft.aggregate query type annotation
1 parent cd3b7fd commit 5fa7a4d

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

redis/commands/search/commands.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -542,7 +542,7 @@ def explain_cli(self, query: Union[str, Query]): # noqa
542542

543543
def aggregate(
544544
self,
545-
query: Union[str, Query],
545+
query: Union[AggregateRequest, Cursor],
546546
query_params: Dict[str, Union[str, int, float]] = None,
547547
):
548548
"""
@@ -573,7 +573,7 @@ def aggregate(
573573
)
574574

575575
def _get_aggregate_result(
576-
self, raw: List, query: Union[str, Query, AggregateRequest], has_cursor: bool
576+
self, raw: List, query: Union[AggregateRequest, Cursor], has_cursor: bool
577577
):
578578
if has_cursor:
579579
if isinstance(query, Cursor):
@@ -967,7 +967,7 @@ async def search(
967967

968968
async def aggregate(
969969
self,
970-
query: Union[str, Query],
970+
query: Union[AggregateResult, Cursor],
971971
query_params: Dict[str, Union[str, int, float]] = None,
972972
):
973973
"""

0 commit comments

Comments
 (0)