7
7
from mongoengine .base import get_document
8
8
from . import advanced_types
9
9
from .utils import import_single_dispatch , get_field_description , get_query_fields
10
- from concurrent .futures import ThreadPoolExecutor , wait , as_completed
10
+ from concurrent .futures import ThreadPoolExecutor , as_completed
11
11
12
12
singledispatch = import_single_dispatch ()
13
13
@@ -112,7 +112,7 @@ def get_reference_objects(*args, **kwargs):
112
112
document_field = mongoengine .ReferenceField (document )
113
113
document_field = convert_mongoengine_field (document_field , registry )
114
114
document_field_type = document_field .get_type ().type ._meta .name
115
- only_fields = [to_snake_case (i ) for i in get_query_fields (args [0 ][3 ])[document_field_type ].keys ()]
115
+ only_fields = [to_snake_case (i ) for i in get_query_fields (args [0 ][3 ][ 0 ] )[document_field_type ].keys ()]
116
116
return document .objects ().no_dereference ().only (* only_fields ).filter (pk__in = args [0 ][1 ])
117
117
else :
118
118
return []
@@ -128,7 +128,7 @@ def reference_resolver(root, *args, **kwargs):
128
128
pool = ThreadPoolExecutor (5 )
129
129
futures = list ()
130
130
for model , object_id_list in choice_to_resolve .items ():
131
- futures .append (pool .submit (get_reference_objects , (model , object_id_list , registry , * args )))
131
+ futures .append (pool .submit (get_reference_objects , (model , object_id_list , registry , args )))
132
132
result = list ()
133
133
for x in as_completed (futures ):
134
134
result += x .result ()
0 commit comments