You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by da...@apache.org on 2017/01/30 18:00:32 UTC
[5/7] tinkerpop git commit: updated traversal source code generator
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 <da...@gmail.com>
Authored: Sat Jan 28 13:45:39 2017 -0500
Committer: davebshow <da...@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