Removed defer from graphql package

Author: syrusakbary

graphql/execution/base.py

@@ -1,7 +1,6 @@
 # -*- coding: utf-8 -*-
 from ..error import GraphQLError
 from ..language import ast
-from ..pyutils.defer import DeferredException
 from ..type.definition import GraphQLInterfaceType, GraphQLUnionType
 from ..type.directives import GraphQLIncludeDirective, GraphQLSkipDirective
 from ..type.introspection import (SchemaMetaFieldDef, TypeMetaFieldDef,
@@ -85,12 +84,6 @@ class ExecutionResult(object):
 
     def __init__(self, data=None, errors=None, invalid=False):
         self.data = data
-        if errors:
-            errors = [
-                error.value if isinstance(error, DeferredException) else error
-                for error in errors
-            ]
-
         self.errors = errors
 
         if invalid:

graphql/execution/tests/test_concurrent_executor.py

@@ -8,7 +8,6 @@
 from graphql.type.definition import GraphQLNonNull
 
 from ..executors.thread import ThreadExecutor
-# from .utils import raise_callback_results
 from .utils import rejected, resolved
 
 

graphql/execution/tests/utils.py

@@ -1,5 +1,4 @@
 from graphql.pyutils.aplus import Promise
-from graphql.pyutils.defer import Deferred, DeferredException, _passthrough
 
 
 def resolved(value):
@@ -8,44 +7,3 @@ def resolved(value):
 
 def rejected(error):
     return Promise.rejected(error)
-
-
-class RaisingDeferred(Deferred):
-
-    def _next(self):
-        """Process the next callback."""
-        if self._running or self.paused:
-            return
-
-        while self.callbacks:
-            # Get the next callback pair
-            next_pair = self.callbacks.pop(0)
-            # Continue with the errback if the last result was an exception
-            callback, args, kwargs = next_pair[isinstance(self.result,
-                                                          DeferredException)]
-
-            if callback is not _passthrough:
-                self._running = True
-                try:
-                    self.result = callback(self.result, *args, **kwargs)
-
-                except:
-                    self.result = DeferredException()
-
-                finally:
-                    self._running = False
-
-                if isinstance(self.result, Exception):
-                    self.result = DeferredException(self.result)
-
-        if isinstance(self.result, DeferredException):
-            # Print the exception to stderr and stop if there aren't any
-            # further errbacks to process
-            self.result.raise_exception()
-
-
-def raise_callback_results(deferred, callback):
-    d = RaisingDeferred()
-    d.add_callback(lambda r: r)
-    d.callback(deferred)
-    d.add_callback(callback)