fakz9/Sipro-Stocks
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: debug

Browse Source
This commit is contained in:
fakz9
2024-10-21 13:14:02 +03:00
parent 36dbce69c0
commit 7daf029a1d
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
limiter/batch_limiter.py
View File

@@ -26,6 +26,7 @@ class BatchLimiter:
async def acquire(self, key, max_requests, period): async def acquire(self, key, max_requests, period):
redis = await RedisConnectionManager.get_redis_connection() redis = await RedisConnectionManager.get_redis_connection()
while True: while True:
logging.info(f'Getting key: {key}')
async with redis.lock(f"{key}_lock"): async with redis.lock(f"{key}_lock"):
try: try:
start_time = await redis.get(f"{key}:start_time") start_time = await redis.get(f"{key}:start_time")