Upgrade anyio to 2.0.0b1

mjwestcott · Aug 17, 2020 · a853f2d · a853f2d · vercel · Aug 17, 2020
1 parent f0bb2b5
commit a853f2d
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 13 deletions.
diff --git a/poetry.lock b/poetry.lock
diff --git a/pyproject.toml b/pyproject.toml
@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "runnel"
-version = "0.1.0-alpha.2"
+version = "0.1.0a2"
 description = "Distributed event processing for Python based on Redis Streams"
 authors = ["Matt Westcott <[email protected]>"]
 license = "LGPLv3"
@@ -16,8 +16,7 @@ colorama = "^0.4.3"
 aiostream = "^0.4.1"
 croniter = "^0.3.34"
 pytz = "^2020.1"
-# XXX: Temporarily using master until v2.0 released
-anyio = {git = "https://github.com/agronholm/anyio.git", branch = "master"}
+anyio = { version = "^2.0.0-beta.1", allow-prereleases = true }
 
 # For the 'fast' bundle
 uvloop = { version = "^0.14.0", optional = true }

diff --git a/runnel/middleware/take.py b/runnel/middleware/take.py
@@ -50,7 +50,7 @@ async def _consume(self, receive_stream):
         for _ in range(self.n):
             try:
                 batch.append(await receive_stream.receive_nowait())
-            except anyio.exceptions.WouldBlock:
+            except anyio.WouldBlock:
                 logger.debug("took-too-few", have=len(batch), wanted=self.n)
                 break
         logger.debug("take-consumed", batch=[e.data for e in batch])