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() {