xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2026-02-19 14:14:26 +00:00
Code Issues Projects Releases Wiki Activity

Do not await synchronous functions

Browse Source
This commit is contained in:
Jarrod Johnson
2024-08-20 17:05:32 -04:00
parent c9e428bb1b
commit 4ef24351aa
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
confluent_server/confluent/log.py
View File

@@ -68,6 +68,7 @@ import collections
import confluent.config.configmanager
import confluent.config.conf as conf
import confluent.exceptions as exc
import inspect
import glob
import json
import os
@@ -117,7 +118,9 @@ _loggers = {}
async def _sleep_and_run(sleeptime, func, args):
await asyncio.sleep(sleeptime)
await func(*args)
awt = func(*args)
if inspect.isawaitable(awt):
await awt
def spawn_after(sleeptime, func, *args):