use create_task instead of ensure_future

channels/layers.py

@@ -198,13 +198,13 @@ def __init__(
         group_expiry=86400,
         capacity=100,
         channel_capacity=None,
-        **kwargs
+        **kwargs,
     ):
         super().__init__(
             expiry=expiry,
             capacity=capacity,
             channel_capacity=channel_capacity,
-            **kwargs
+            **kwargs,
         )
         self.channels = {}
         self.groups = {}
@@ -287,7 +287,6 @@ def _clean_expired(self):
         # Group Expiration
         timeout = int(time.time()) - self.group_expiry
         for channels in self.groups.values():
-
             for name, timestamp in list(channels.items()):
                 # If join time is older than group_expiry
                 # end the group membership
@@ -349,7 +348,7 @@ async def group_send(self, group, message):
         ops = []
         if group in self.groups:
             for channel in self.groups[group].keys():
-                ops.append(asyncio.ensure_future(self.send(channel, message)))
+                ops.append(asyncio.create_task(self.send(channel, message)))
         for send_result in asyncio.as_completed(ops):
             try:
                 await send_result

tests/test_inmemorychannel.py

@@ -46,7 +46,7 @@ async def test_race_empty(channel_layer):
     """
     Makes sure the race is handled gracefully.
     """
-    receive_task = asyncio.ensure_future(channel_layer.receive("test-channel-1"))
+    receive_task = asyncio.create_task(channel_layer.receive("test-channel-1"))
     await asyncio.sleep(0.1)
     await channel_layer.send(
         "test-channel-1", {"type": "test.message", "text": "Ahoy-hoy!"}