This commit is contained in:
@@ -61,6 +61,7 @@ class RedisCache:
|
||||
yield json.loads(message["data"]), message.get("channel")
|
||||
except Exception as e:
|
||||
print(f"[servoces.rediscache] Error: {e}")
|
||||
await asyncio.sleep(1)
|
||||
|
||||
|
||||
redis = RedisCache()
|
||||
|
Reference in New Issue
Block a user