rethinkdb restarted

Author: phenobarbital

asyncdb/drivers/cassandra.py

@@ -3,7 +3,7 @@
 
 Cassandra Driver for asyncDB.
 
-TODO: migrate to Thread Executors or Asyncio version.
+TODO: migrate to Asyncio version (when available).
 """
 import time
 import logging

asyncdb/drivers/rethink.py

@@ -77,6 +77,8 @@ async def __anext__(self):
         """Use `cursor.fetchrow()` to provide an async iterable."""
         try:
             row = await self._cursor.next()
+        except AttributeError:
+            row = None
         except rethinkdb.errors.ReqlCursorEmpty:
             row = None
         if row is not None:

asyncdb/interfaces.py

@@ -542,7 +542,7 @@ def __init__(
         parameters: Iterable[Any] = None,
         **kwargs
     ):
-        # self._cursor = None
+        self._cursor = None
         self._provider = provider
         self._result = result
         self._sentence = sentence

setup.py

@@ -132,7 +132,7 @@ def readme():
             "aiomcache==0.8.1",
             "aiosqlite>=0.18.0",
             "cassandra-driver==3.28.0",
-            "rethinkdb==2.4.9",
+            "rethinkdb==2.4.10",
             "influxdb==5.3.1",
             "influxdb-client[async]==1.39.0",
             "pymssql==2.2.7",
@@ -168,7 +168,7 @@ def readme():
             "objectpath==0.6.1",
         ],
         "rethinkdb": [
-            "rethinkdb==2.4.9",
+            "rethinkdb==2.4.10",
         ],
         "postgres": [
             "aiopg==1.4.0",
@@ -244,7 +244,7 @@ def readme():
             "aioredis==2.0.1",
             "redis==5.0.1",
             "objectpath==0.6.1",
-            "rethinkdb==2.4.9",
+            "rethinkdb==2.4.10",
             "aiopg==1.4.0",
             "psycopg-binary>=3.1.8",
             "cassandra-driver==3.28.0",

tests/test_rethink.py

@@ -19,8 +19,8 @@
     "host": "localhost",
     "port": "28015",
     "db": "epson",
-    "user": "test",
-    "password": "supersecret"
+#     "user": "test",
+#     "password": "supersecret"
 }