|
|
@ -1274,7 +1274,7 @@ class Queue:
|
|
|
|
if timeout is not None: # blocking variant
|
|
|
|
if timeout is not None: # blocking variant
|
|
|
|
if timeout == 0:
|
|
|
|
if timeout == 0:
|
|
|
|
raise ValueError('RQ does not support indefinite timeouts. Please pick a timeout value > 0')
|
|
|
|
raise ValueError('RQ does not support indefinite timeouts. Please pick a timeout value > 0')
|
|
|
|
colored_queues = ''.join(map(str, [green(str(queue)) for queue in queue_keys]))
|
|
|
|
colored_queues = ', '.join(map(str, [green(str(queue)) for queue in queue_keys]))
|
|
|
|
logger.debug(f"Starting BLPOP operation for queues {colored_queues} with timeout of {timeout}")
|
|
|
|
logger.debug(f"Starting BLPOP operation for queues {colored_queues} with timeout of {timeout}")
|
|
|
|
result = connection.blpop(queue_keys, timeout)
|
|
|
|
result = connection.blpop(queue_keys, timeout)
|
|
|
|
if result is None:
|
|
|
|
if result is None:
|
|
|
|