Skip to content

Commit 0ff1005

Browse files
authored
Update plugin.py
apparently close() is needed instead of aclose()
1 parent f4a4a02 commit 0ff1005

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

privex/helpers/plugin.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -338,7 +338,7 @@ async def close_redis_async(thread_id=None, close_all=False) -> bool:
338338
continue
339339
log.debug("Closing aioredis for thread ID %s", t_id)
340340
try:
341-
await rd.aclose()
341+
await rd.close()
342342
except RuntimeError as err:
343343
log.warning("[ignored] RuntimeError while closing aioredis (thread %s): %s - %s", thread_id, type(err), str(err))
344344
except Exception:
@@ -348,7 +348,7 @@ async def close_redis_async(thread_id=None, close_all=False) -> bool:
348348
rd = _get_threadstore('aioredis', 'NOT_FOUND', thread_id=thread_id)
349349
if rd != 'NOT_FOUND':
350350
try:
351-
await rd.aclose()
351+
await rd.close()
352352
except RuntimeError as err:
353353
log.warning("[ignored] RuntimeError while closing aioredis (thread %s): %s - %s", thread_id, type(err), str(err))
354354
clean_threadstore(thread_id=thread_id, name='aioredis')

0 commit comments

Comments
 (0)