You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by sp...@apache.org on 2018/08/28 16:30:55 UTC
tinkerpop git commit: TINKERPOP-2021 Added test to simulate maximum
recursion depth failure
Repository: tinkerpop
Updated Branches:
refs/heads/TINKERPOP-2021 [created] db866059e
TINKERPOP-2021 Added test to simulate maximum recursion depth failure
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/db866059
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/db866059
Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/db866059
Branch: refs/heads/TINKERPOP-2021
Commit: db866059e4abd6338aab972c159bec7fe643e768
Parents: 47e0600
Author: Stephen Mallette <sp...@genoprime.com>
Authored: Tue Aug 28 11:58:13 2018 -0400
Committer: Stephen Mallette <sp...@genoprime.com>
Committed: Tue Aug 28 11:58:13 2018 -0400
----------------------------------------------------------------------
.../src/main/jython/tests/driver/test_client.py | 44 ++++++++++++++++++++
1 file changed, 44 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/db866059/gremlin-python/src/main/jython/tests/driver/test_client.py
----------------------------------------------------------------------
diff --git a/gremlin-python/src/main/jython/tests/driver/test_client.py b/gremlin-python/src/main/jython/tests/driver/test_client.py
index 595aba0..82b0221 100644
--- a/gremlin-python/src/main/jython/tests/driver/test_client.py
+++ b/gremlin-python/src/main/jython/tests/driver/test_client.py
@@ -20,6 +20,7 @@ import pytest
from gremlin_python.driver.client import Client
from gremlin_python.driver.request import RequestMessage
+from gremlin_python.process.graph_traversal import __
from gremlin_python.structure.graph import Graph
__author__ = 'David M. Brown (davebshow@gmail.com)'
@@ -107,3 +108,46 @@ def test_multi_conn_pool(client):
# with connection pool `future` may or may not be done here
result_set = future.result()
assert len(result_set.all().result()) == 6
+
+
+def test_big_result_set(client):
+ g = Graph().traversal()
+ t = g.inject(1).repeat(__.addV('person').property('name', __.loops())).times(20000).count()
+ message = RequestMessage('traversal', 'bytecode', {'gremlin': t.bytecode, 'aliases': {'g': 'g'}})
+ result_set = client.submit(message)
+ results = []
+ for result in result_set:
+ results += result
+ assert len(results) == 1
+
+ t = g.V().limit(10)
+ message = RequestMessage('traversal', 'bytecode', {'gremlin': t.bytecode, 'aliases': {'g': 'g'}})
+ result_set = client.submit(message)
+ results = []
+ for result in result_set:
+ results += result
+ assert len(results) == 10
+
+ t = g.V().limit(100)
+ message = RequestMessage('traversal', 'bytecode', {'gremlin': t.bytecode, 'aliases': {'g': 'g'}})
+ result_set = client.submit(message)
+ results = []
+ for result in result_set:
+ results += result
+ assert len(results) == 100
+
+ t = g.V().limit(1000)
+ message = RequestMessage('traversal', 'bytecode', {'gremlin': t.bytecode, 'aliases': {'g': 'g'}})
+ result_set = client.submit(message)
+ results = []
+ for result in result_set:
+ results += result
+ assert len(results) == 1000
+
+ t = g.V().limit(10000)
+ message = RequestMessage('traversal', 'bytecode', {'gremlin': t.bytecode, 'aliases': {'g': 'g'}})
+ result_set = client.submit(message)
+ results = []
+ for result in result_set:
+ results += result
+ assert len(results) == 10000