Fix compatibility with Python 3.10, refs aio-libs#358

simonw · Oct 8, 2021 · 9e13d3f · 9e13d3f
1 parent d7970f8
commit 9e13d3f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
@@ -43,7 +43,7 @@ jobs:
     needs: lint
     strategy:
       matrix:
-        python-version: [3.6, 3.7, 3.8, 3.9]
+        python-version: ["3.6", "3.7", "3.8", "3.9", "3.10"]
         os: [ubuntu]
       fail-fast:
         false

diff --git a/janus/__init__.py b/janus/__init__.py
@@ -36,6 +36,8 @@ def __init__(self, maxsize: int = 0) -> None:
         self._all_tasks_done = threading.Condition(self._sync_mutex)
 
         self._async_mutex = asyncio.Lock()
+        # Workaround for Python 3.10 bug, see #358:
+        getattr(self._async_mutex, '_get_loop', lambda: None)()
         self._async_not_empty = asyncio.Condition(self._async_mutex)
         self._async_not_full = asyncio.Condition(self._async_mutex)
         self._finished = asyncio.Event()