diff --git a/graphene_django/fields.py b/graphene_django/fields.py index c8899de..6e1b0b1 100644 --- a/graphene_django/fields.py +++ b/graphene_django/fields.py @@ -240,7 +240,7 @@ class DjangoConnectionField(ConnectionField): iterable = resolver(root, info, **args) if info.is_awaitable(iterable): - async def resolve_connection_async(): + async def resolve_connection_async(iterable): iterable = await iterable if iterable is None: iterable = default_manager @@ -251,7 +251,7 @@ class DjangoConnectionField(ConnectionField): iterable = await iterable return await sync_to_async(cls.resolve_connection)(connection, args, iterable, max_limit=max_limit) - return resolve_connection_async() + return resolve_connection_async(iterable) if iterable is None: iterable = default_manager diff --git a/graphene_django/filter/fields.py b/graphene_django/filter/fields.py index a141460..c62ee9c 100644 --- a/graphene_django/filter/fields.py +++ b/graphene_django/filter/fields.py @@ -95,14 +95,14 @@ class DjangoFilterConnectionField(DjangoConnectionField): qs = super().resolve_queryset(connection, iterable, info, args) if info.is_awaitable(qs): - async def filter_async(): + async def filter_async(qs): filterset = filterset_class( data=filter_kwargs(), queryset=await qs, request=info.context ) if await sync_to_async(filterset.is_valid)(): return filterset.qs raise ValidationError(filterset.form.errors.as_json()) - return filter_async() + return filter_async(qs) filterset = filterset_class( data=filter_kwargs(), queryset=qs, request=info.context