wyj/starbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: Fixed task was destroyed but it is pending (CPython #91887)

Browse Source
This commit is contained in:
LWR
2023-02-14 22:22:01 +08:00
parent 6fc1ce4631
commit d46ec75dcb
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
starbot/utils/AsyncEvent.py
View File

@@ -14,6 +14,7 @@ class AsyncEvent:
""" """
__handlers: Optional[Dict] = {} __handlers: Optional[Dict] = {}
__running_tasks = set()
def __init__(self): def __init__(self):
self.__handlers = {} self.__handlers = {}
@@ -74,7 +75,9 @@ class AsyncEvent:
name = name.upper() name = name.upper()
if name in self.__handlers: if name in self.__handlers:
for coroutine in self.__handlers[name]: for coroutine in self.__handlers[name]:
asyncio.create_task(coroutine(data)) task = asyncio.create_task(coroutine(data))
self.__running_tasks.add(task)
task.add_done_callback(lambda t: self.__running_tasks.remove(t))
if name != '__ALL__': if name != '__ALL__':
self.dispatch('__ALL__', { self.dispatch('__ALL__', {