Home-IoT/craftbeerpi4-pione
1
0
Fork 0
mirror of https://github.com/PiBrewing/craftbeerpi4.git synced 2024-11-21 22:48:16 +01:00
Code Issues Projects Releases Packages Wiki Activity

removed loop from asyncio.queue (depracted since py 3.9 and removed in 3.10)

Browse source
This commit is contained in:
avollkopf 2022-11-27 10:49:59 +01:00
parent f83ee71369
commit f13993db31
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
cbpi/__init__.py
View file

@ -1,3 +1,3 @@
__version__ = "4.0.7.a8" __version__ = "4.0.7.a9"
__codename__ = "Spring Break" __codename__ = "Spring Break"

4
cbpi/job/_scheduler.py
View file

@ -21,9 +21,9 @@ class Scheduler(*bases):
self._close_timeout = close_timeout self._close_timeout = close_timeout
self._limit = limit self._limit = limit
self._exception_handler = exception_handler 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._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 self._closed = False
def __iter__(self): def __iter__(self):