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/15 21:24:14 UTC
tinkerpop git commit: fixed typo in parser
Repository: tinkerpop
Updated Branches:
refs/heads/python_driver 0298b77de -> 3b1a347c7
fixed typo in parser
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/3b1a347c
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/3b1a347c
Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/3b1a347c
Branch: refs/heads/python_driver
Commit: 3b1a347c77734873137a596d9d37f44b998387f7
Parents: 0298b77
Author: davebshow <da...@gmail.com>
Authored: Sun Jan 15 16:24:02 2017 -0500
Committer: davebshow <da...@gmail.com>
Committed: Sun Jan 15 16:24:02 2017 -0500
----------------------------------------------------------------------
gremlin-python/src/main/jython/gremlin_python/driver/protocol.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/3b1a347c/gremlin-python/src/main/jython/gremlin_python/driver/protocol.py
----------------------------------------------------------------------
diff --git a/gremlin-python/src/main/jython/gremlin_python/driver/protocol.py b/gremlin-python/src/main/jython/gremlin_python/driver/protocol.py
index 70404d4..a8f183b 100644
--- a/gremlin-python/src/main/jython/gremlin_python/driver/protocol.py
+++ b/gremlin-python/src/main/jython/gremlin_python/driver/protocol.py
@@ -67,7 +67,7 @@ class GremlinServerWSProtocol(AbstractBaseProtocol):
if status_code == 407:
self._authenticate(request_id)
data = self._transport.read()
- self.receive(data, response_queues)
+ self.data_received(data, results_dict)
elif status_code == 204:
# result_set.stream.put_nowait([None])
result_set.done.set_result(None)
@@ -80,7 +80,7 @@ class GremlinServerWSProtocol(AbstractBaseProtocol):
result_set.stream.put_nowait(results)
if status_code == 206:
data = self._transport.read()
- self.receive(data, response_queues)
+ self.data_received(data, results_dict)
else:
result_set.done.set_result(None)
del results_dict[request_id]