Python3.10 support

aioriak/datatypes/map.py

@@ -1,6 +1,6 @@
 from .datatype import Datatype
 from . import TYPES
-from collections import Mapping
+from collections.abc import Mapping
 from riak.util import lazy_property
 
 

aioriak/datatypes/register.py

@@ -1,4 +1,4 @@
-from collections import Sized
+from collections.abc import Sized
 from aioriak.datatypes.datatype import Datatype
 from aioriak.datatypes import TYPES
 

aioriak/datatypes/set.py

@@ -3,7 +3,7 @@
 from aioriak.datatypes import TYPES
 
 
-class Set(collections.Set, Datatype):
+class Set(collections.abc.Set, Datatype):
  '''A convergent datatype representing a Set with observed-remove
  semantics. Currently strings are the only supported value type.
 
@@ -93,7 +93,7 @@ def _coerce_value(self, new_value):
  return frozenset(new_value)
 
  def _check_type(self, new_value):
- if not isinstance(new_value, collections.Iterable):
+ if not isinstance(new_value, collections.abc.Iterable):
  return False
  for element in new_value:
  if not isinstance(element, str):

aioriak/transport.py

@@ -47,7 +47,7 @@ def _encode_link_field(value):
 
 async def create_transport(host='localhost', port=8087, loop=None):
  reader, writer = await asyncio.open_connection(
- host, port, loop=loop)
+ host, port)
  conn = RiakPbcAsyncTransport(reader, writer, loop=loop)
  return conn
 

requirements.txt

@@ -1 +1 @@
-riak==2.7.0
+riak @ git+https://github.com/StreetHawkInc/riak-python-client.git@master