summaryrefslogtreecommitdiff
path: root/redis/asyncio/lock.py
diff options
context:
space:
mode:
authordvora-h <67596500+dvora-h@users.noreply.github.com>2023-01-05 14:33:10 +0200
committerGitHub <noreply@github.com>2023-01-05 14:33:10 +0200
commite67d15c490585de3f350b91ee9a4e12d3ba134b7 (patch)
tree97edd622ca5c147fd3d7878a11c7b5ace427d3e6 /redis/asyncio/lock.py
parentf14ed1fc822a88a21bbfc64e36bf8b09e5c9386c (diff)
downloadredis-py-e67d15c490585de3f350b91ee9a4e12d3ba134b7.tar.gz
replase get_event_loop wite get_running_loop (#2530)
Diffstat (limited to 'redis/asyncio/lock.py')
-rw-r--r--redis/asyncio/lock.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/redis/asyncio/lock.py b/redis/asyncio/lock.py
index 2f78d69..e1d11a8 100644
--- a/redis/asyncio/lock.py
+++ b/redis/asyncio/lock.py
@@ -201,14 +201,14 @@ class Lock:
blocking_timeout = self.blocking_timeout
stop_trying_at = None
if blocking_timeout is not None:
- stop_trying_at = asyncio.get_event_loop().time() + blocking_timeout
+ stop_trying_at = asyncio.get_running_loop().time() + blocking_timeout
while True:
if await self.do_acquire(token):
self.local.token = token
return True
if not blocking:
return False
- next_try_at = asyncio.get_event_loop().time() + sleep
+ next_try_at = asyncio.get_running_loop().time() + sleep
if stop_trying_at is not None and next_try_at > stop_trying_at:
return False
await asyncio.sleep(sleep)