Skip to content

Commit e708799

Browse files
committed
fix: add a timeout to RedisSteamBroker xautoclaim lock to prevent infinite locking
1 parent f03a4a3 commit e708799

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

taskiq_redis/redis_broker.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -198,8 +198,8 @@ def __init__(
198198
:param additional_streams: additional streams to read from.
199199
Each key is a stream name, value is a consumer id.
200200
:param unacknowledged_batch_size: number of unacknowledged messages to fetch.
201-
:param unacknowledged_lock_timeout: time in seconds before auto-releasing the lock.
202-
After this time the lock will be automatically released if the worker crashes or gets killed.
201+
:param unacknowledged_lock_timeout: time in seconds before auto-releasing
202+
the lock. Useful when the worker crashes or gets killed.
203203
Set to a bigger value if your tasks take a long time to complete.
204204
"""
205205
super().__init__(

0 commit comments

Comments
 (0)