Skip to content

Commit 03027bb

Browse files
authored
Missed some redis.aclose() references
1 parent 0ff1005 commit 03027bb

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
@@ -255,14 +255,14 @@ def close_redis(thread_id=None, close_all=False) -> bool:
255255
continue
256256
log.debug("Closing redis for thread ID %s", t_id)
257257
try:
258-
rd.aclose()
258+
rd.close()
259259
except Exception:
260260
log.exception("Exception while closing redis for thread ID %s", t_id)
261261
return clean_threadstore(name='redis', clean_all=True)
262262

263263
rd: Union[str, redis.Redis] = _get_threadstore('redis', 'NOT_FOUND', thread_id=thread_id)
264264
if rd != 'NOT_FOUND':
265-
rd.aclose()
265+
rd.close()
266266
clean_threadstore(thread_id=thread_id, name='redis')
267267
return True
268268
return False

0 commit comments

Comments
 (0)