fix: 更新Redis队列处理逻辑以返回空队列状态
This commit is contained in:
parent
b0745aa420
commit
1847b34c64
3
DB.py
3
DB.py
@ -286,6 +286,9 @@ class DBVidcon:
|
|||||||
logger.info("[Redis l2 pop error]", e)
|
logger.info("[Redis l2 pop error]", e)
|
||||||
self.reconnect_redis()
|
self.reconnect_redis()
|
||||||
items = []
|
items = []
|
||||||
|
if items:
|
||||||
|
return items, 2
|
||||||
|
logger.info("[Redis queues empty] 所有队列均为空")
|
||||||
return items, 99
|
return items, 99
|
||||||
|
|
||||||
@redis_retry(max_retries=3)
|
@redis_retry(max_retries=3)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user