Muttered3 commited on
Commit
363aa04
·
verified ·
1 Parent(s): abee082

Update db.py

Browse files
Files changed (1) hide show
  1. db.py +7 -2
db.py CHANGED
@@ -6,7 +6,13 @@ _redis = None
6
  async def get_redis():
7
  global _redis
8
  if _redis is None:
9
- _redis = aioredis.from_url(os.environ["REDIS_URL"], decode_responses=True)
 
 
 
 
 
 
10
  return _redis
11
 
12
  async def queue_size() -> int:
@@ -68,7 +74,6 @@ async def get_all_sold() -> list:
68
  r = await get_redis()
69
  return list(await r.smembers("frag:sold"))
70
 
71
- # ---> NEW FUNCTIONS ADDED HERE <---
72
  async def get_all_forsale() -> list:
73
  r = await get_redis()
74
  return list(await r.smembers("frag:forsale"))
 
6
  async def get_redis():
7
  global _redis
8
  if _redis is None:
9
+ # CRITICAL FIX: Limit max_connections to prevent free-tier Redis crashes
10
+ _redis = aioredis.from_url(
11
+ os.environ["REDIS_URL"],
12
+ decode_responses=True,
13
+ max_connections=15,
14
+ socket_timeout=10
15
+ )
16
  return _redis
17
 
18
  async def queue_size() -> int:
 
74
  r = await get_redis()
75
  return list(await r.smembers("frag:sold"))
76
 
 
77
  async def get_all_forsale() -> list:
78
  r = await get_redis()
79
  return list(await r.smembers("frag:forsale"))