removed loop from asyncio.queue (depracted since py 3.9 and removed i…

…n 3.10)
DaSchaef · Nov 27, 2022 · f13993d · f13993d
1 parent f83ee71
commit f13993d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/cbpi/__init__.py b/cbpi/__init__.py
@@ -1,3 +1,3 @@
-__version__ = "4.0.7.a8"
+__version__ = "4.0.7.a9"
 __codename__ = "Spring Break"
 
diff --git a/cbpi/job/_scheduler.py b/cbpi/job/_scheduler.py
@@ -21,9 +21,9 @@ def __init__(self, cbpi, *, close_timeout, limit, pending_limit,
         self._close_timeout = close_timeout
         self._limit = limit
         self._exception_handler = exception_handler
-        self._failed_tasks = asyncio.Queue(loop=loop)
+        self._failed_tasks = asyncio.Queue()
         self._failed_task = loop.create_task(self._wait_failed())
-        self._pending = asyncio.Queue(maxsize=pending_limit, loop=loop)
+        self._pending = asyncio.Queue(maxsize=pending_limit)
         self._closed = False
 
     def __iter__(self):