updated traversal source code generator
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/cdbacc0c Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/cdbacc0c Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/cdbacc0c Branch: refs/heads/TINKERPOP-1599 Commit: cdbacc0c05ef47189fec840e4a3fad6d26f25fea Parents: 0078638 Author: davebshow <davebs...@gmail.com> Authored: Sat Jan 28 13:45:39 2017 -0500 Committer: davebshow <davebs...@gmail.com> Committed: Mon Jan 30 11:51:24 2017 -0500 ---------------------------------------------------------------------- .../gremlin/python/TraversalSourceGenerator.groovy | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/cdbacc0c/gremlin-python/src/main/groovy/org/apache/tinkerpop/gremlin/python/TraversalSourceGenerator.groovy ---------------------------------------------------------------------- diff --git a/gremlin-python/src/main/groovy/org/apache/tinkerpop/gremlin/python/TraversalSourceGenerator.groovy b/gremlin-python/src/main/groovy/org/apache/tinkerpop/gremlin/python/TraversalSourceGenerator.groovy index fc76b71..995fe80 100644 --- a/gremlin-python/src/main/groovy/org/apache/tinkerpop/gremlin/python/TraversalSourceGenerator.groovy +++ b/gremlin-python/src/main/groovy/org/apache/tinkerpop/gremlin/python/TraversalSourceGenerator.groovy @@ -116,15 +116,16 @@ class Traversal(object): return tempList def promise(self, cb=None): self.traversal_strategies.apply_async_strategies(self) - future_traversers = self.traversers - future = type(future_traversers)() + future_traversal = self.remote_results + future = type(future_traversal)() def process(f): try: - traversers = f.result() + traversal = f.result() except Exception as e: future.set_exception(e) else: - self.traversers = iter(traversers) + self.traversers = iter(traversal.traversers) + self.side_effects = traversal.side_effects if cb: try: result = cb(self) @@ -134,7 +135,7 @@ class Traversal(object): future.set_result(result) else: future.set_result(self) - future_traversers.add_done_callback(process) + future_traversal.add_done_callback(process) return future