Repository: tinkerpop Updated Branches: refs/heads/master 90940d38d -> 95f7080fd
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/425bcd03 Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/425bcd03 Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/425bcd03 Branch: refs/heads/master Commit: 425bcd032adc9967a6b575da8042df3806671825 Parents: e937a3a Author: Stephen Mallette <[email protected]> Authored: Tue Aug 28 11:58:13 2018 -0400 Committer: Stephen Mallette <[email protected]> Committed: Tue Sep 4 13:24:18 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/425bcd03/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 ([email protected])' @@ -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
