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):