From 0926888213ba166a73a92ae4dc5cd2c06be21b3a Mon Sep 17 00:00:00 2001
From: Alexander <zavorotynskiy@pm.me>
Date: Fri, 16 May 2025 16:58:04 +0200
Subject: [PATCH] feat(redis): increased the block duration for read operation

---
 backend/pkg/redisstream/consumer.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/backend/pkg/redisstream/consumer.go b/backend/pkg/redisstream/consumer.go
index c06e69c3a..a5d6a048a 100644
--- a/backend/pkg/redisstream/consumer.go
+++ b/backend/pkg/redisstream/consumer.go
@@ -80,7 +80,7 @@ func (c *Consumer) ConsumeNext() error {
 		Consumer: c.group,
 		Streams:  c.streams,
 		Count:    int64(READ_COUNT),
-		Block:    200 * time.Millisecond,
+		Block:    2000 * time.Millisecond,
 	}).Result()
 	if err != nil {
 		if err, ok := err.(net.Error); ok && err.Timeout() {