From f13993db31a8ccb9a506eb98a8b9d673fd64b244 Mon Sep 17 00:00:00 2001
From: avollkopf <43980694+avollkopf@users.noreply.github.com>
Date: Sun, 27 Nov 2022 10:49:59 +0100
Subject: [PATCH] removed loop from asyncio.queue (depracted since py 3.9 and
 removed in 3.10)

---
 cbpi/__init__.py       | 2 +-
 cbpi/job/_scheduler.py | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/cbpi/__init__.py b/cbpi/__init__.py
index 8bcc9ae..54abc01 100644
--- 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
index 28db254..9393759 100644
--- a/cbpi/job/_scheduler.py
+++ b/cbpi/job/_scheduler.py
@@ -21,9 +21,9 @@ class Scheduler(*bases):
         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):