|
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