Fix consumer fetcher for python3.9 (#672)

aio-libs · Oct 27, 2020 · 1d2e02e · 1d2e02e
1 parent 48f5df5
commit 1d2e02e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/CHANGES/python3.9-fix.bugfix b/CHANGES/python3.9-fix.bugfix
@@ -0,0 +1 @@
+Fix consumer fetcher for python3.9
diff --git a/aiokafka/consumer/fetcher.py b/aiokafka/consumer/fetcher.py
@@ -530,7 +530,9 @@ def on_done(fut, self=self):
                     other_futs.append(fut)
 
                 done_set, _ = await asyncio.wait(
-                    chain(self._pending_tasks, other_futs, resume_futures),
+                    set(
+                        chain(self._pending_tasks, other_futs, resume_futures)
+                    ),
                     timeout=timeout,
                     return_when=asyncio.FIRST_COMPLETED)