Fall back to asyncio.async when asyncio.ensure_future is not available.

jonathanslenders · jonathanslenders · commit 68687da16eca · 2016-03-17T21:30:02.000+01:00
diff --git a/asyncio_redis/connection.py b/asyncio_redis/connection.py
@@ -7,6 +7,13 @@
 __all__ = ('Connection', )
 
 
+# In Python 3.4.4, `async` was renamed to `ensure_future`.
+try:
+    ensure_future = asyncio.ensure_future
+except AttributeError:
+    ensure_future = asyncio.async
+
+
 class Connection:
     """
     Wrapper around the protocol and transport which takes care of establishing
@@ -54,7 +61,7 @@ def create(cls, host='localhost', port=6379, *, password=None, db=0,
         # Create protocol instance
         def connection_lost():
             if connection._auto_reconnect and not connection._closing:
-                asyncio.ensure_future(connection._reconnect(), loop=connection._loop)
+                ensure_future(connection._reconnect(), loop=connection._loop)
 
         # Create protocol instance
         connection.protocol = protocol_class(password=password, db=db, encoder=encoder,
