fix
This commit is contained in:
@@ -1,5 +1,5 @@
|
||||
import os
|
||||
import redis.asyncio
|
||||
import redis.asyncio as connection
|
||||
|
||||
|
||||
REDIS_HOST = os.getenv('REDIS_HOST', 'localhost')
|
||||
@@ -11,5 +11,5 @@ else:
|
||||
|
||||
|
||||
|
||||
pool = redis.asyncio.ConnectionPool.from_url(URL)
|
||||
database = redis.Redis.from_pool(pool)
|
||||
pool = connection.from_url(URL)
|
||||
database = connection.Redis.from_pool(pool)
|
||||
|
||||
@@ -1,8 +0,0 @@
|
||||
import contextlib
|
||||
|
||||
from app.storage import redis
|
||||
|
||||
|
||||
@contextlib.contextmanager
|
||||
def acquire(lock_name: str):
|
||||
return redis.database.lock(lock_name)
|
||||
Reference in New Issue
Block a user