fix: increase the limit for redis queues length (#170)

threefoldtech · Oct 3, 2023 · 5a5d4cb · 5a5d4cb
1 parent d76e63d
commit 5a5d4cb
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/peer/storage/redis_storage.rs b/src/peer/storage/redis_storage.rs
@@ -16,6 +16,8 @@ use bb8_redis::{
 
 struct BacklogKey<'a>(&'a str);
 
+const MAX_COMMANDS: isize = 10000;
+
 impl<'a> ToRedisArgs for BacklogKey<'a> {
     fn write_redis_args<W>(&self, out: &mut W)
     where
@@ -95,7 +97,7 @@ impl RedisStorageBuilder {
     pub fn new(pool: Pool<RedisConnectionManager>) -> RedisStorageBuilder {
         RedisStorageBuilder {
             pool,
-            max_commands: 500,
+            max_commands: MAX_COMMANDS,
         }
     }