up to python 3.10

rethinkdb/ast.py

@@ -92,7 +92,7 @@ def expr(val, nesting_depth=20):
 
     if isinstance(val, RqlQuery):
         return val
-    elif isinstance(val, collections.Callable):
+    elif isinstance(val, collections.abc.Callable):
         return Func(val)
     elif isinstance(val, (datetime.datetime, datetime.date)):
         if not hasattr(val, "tzinfo") or not val.tzinfo:

rethinkdb/asyncio_net/net_asyncio.py

@@ -202,7 +202,7 @@ def connect(self, timeout):
             self._streamreader, self._streamwriter = yield from asyncio.open_connection(
                 self._parent.host,
                 self._parent.port,
-                loop=self._io_loop,
+                #loop=self._io_loop, droped at py3.10
                 ssl=ssl_context,
             )
             self._streamwriter.get_extra_info("socket").setsockopt(