|
32 | 32 |
|
33 | 33 | def graphql(*args, **kwargs):
|
34 | 34 | return_promise = kwargs.get('return_promise', False)
|
35 |
| - promise_result = graphql_impl(*args, **kwargs) |
36 |
| - if not return_promise: |
37 |
| - return promise_result.get() |
| 35 | + if return_promise: |
| 36 | + return execute_graphql_as_promise(*args, **kwargs) |
| 37 | + else: |
| 38 | + return execute_graphql(*args, **kwargs) |
38 | 39 |
|
39 |
| - return promise_result |
40 | 40 |
|
41 |
| - |
42 |
| -@promisify |
43 |
| -def graphql_impl(schema, request_string='', root_value=None, context_value=None, |
44 |
| - variable_values=None, operation_name=None, executor=None, |
45 |
| - return_promise=False, middleware=None): |
| 41 | +def execute_graphql(schema, request_string='', root_value=None, context_value=None, |
| 42 | + variable_values=None, operation_name=None, executor=None, |
| 43 | + return_promise=False, middleware=None): |
46 | 44 | try:
|
47 | 45 | if isinstance(request_string, Document):
|
48 | 46 | ast = request_string
|
@@ -71,3 +69,8 @@ def graphql_impl(schema, request_string='', root_value=None, context_value=None,
|
71 | 69 | errors=[e],
|
72 | 70 | invalid=True,
|
73 | 71 | )
|
| 72 | + |
| 73 | + |
| 74 | +@promisify |
| 75 | +def execute_graphql_as_promise(*args, **kwargs): |
| 76 | + return execute_graphql(*args, **kwargs) |
0 commit comments