Commit aa8e69f4 authored by davebshow's avatar davebshow
Browse files

ready for M9 release

parent 2357f109
# aiogremlin 0.0.8 [(gizmo grew up)](https://pypi.python.org/pypi/gizmo/0.1.12)
# aiogremlin 0.0.9 [(gizmo grew up)](https://pypi.python.org/pypi/gizmo/0.1.12)
`aiogremlin` is a **Python 3** driver for the the [Tinkerpop 3 Gremlin Server](http://tinkerpop.incubator.apache.org/docs/3.0.0.M9-incubating/#gremlin-server). This module is built on [Asyncio](https://docs.python.org/3/library/asyncio.html) and [aiohttp](http://aiohttp.readthedocs.org/en/v0.15.3/index.html) `aiogremlin` is currently in **alpha** mode, but all major functionality has test coverage.
`aiogremlin` is a **Python 3** driver for the the [Tinkerpop 3 Gremlin Server](http://www.tinkerpop.com/docs/3.0.0.M7/#gremlin-server). This module is built on [Asyncio](https://docs.python.org/3/library/asyncio.html) and [aiohttp](http://aiohttp.readthedocs.org/en/v0.15.3/index.html) `aiogremlin` is currently in **alpha** mode, but all major functionality has test coverage.
## Getting started
......
......@@ -4,4 +4,4 @@ from .exceptions import *
from .pool import *
from .subprotocol import *
__version__ = "0.0.8"
__version__ = "0.0.9"
......@@ -198,22 +198,15 @@ class GremlinResponseStream:
@asyncio.coroutine
def read(self):
# For 3.0.0.M9
# if self._stream.at_eof():
# self._pool.release(self._conn)
# message = None
# else:
# asyncio.async(self._conn.receive())
# This will be different 3.0.0.M9
try:
yield from self._conn.receive()
except RequestError:
if self._pool:
self._pool.release(self._conn)
if self._stream.is_eof():
if self._stream.at_eof():
if self._pool:
self._pool.release(self._conn)
message = None
else:
message = yield from self._stream.read()
asyncio.async(self._conn.receive(), loop=self._loop)
try:
message = yield from self._stream.read()
except RequestError:
if self._pool:
self._pool.release(self._conn)
return message
......@@ -30,17 +30,12 @@ def gremlin_response_parser(out, buf):
message["status"]["message"])
if message.status_code == 200:
out.feed_data(message)
# For 3.0.0.M9
# out.feed_eof()
# This will be terminated in 3.0.0.M9
elif message.status_code == 299:
out.feed_eof()
# For 3.0.0.M9
# elif message.status_code == 206:
# out.feed_data(message)
# elif message.status_code == 204:
# out.feed_data(message)
# out.feed_eof()
elif message.status_code == 206:
out.feed_data(message)
elif message.status_code == 204:
out.feed_data(message)
out.feed_eof()
else:
if message.status_code < 500:
raise RequestError(message.status_code, message.message)
......
......@@ -3,7 +3,7 @@ from setuptools import setup
setup(
name="aiogremlin",
version="0.0.8",
version="0.0.9",
url="",
license="MIT",
author="davebshow",
......@@ -12,7 +12,7 @@ setup(
long_description=open("README.txt").read(),
packages=["aiogremlin", "tests"],
install_requires=[
"aiohttp==0.16.0"
"aiohttp==0.16.3"
],
test_suite="tests",
classifiers=[
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment