diff --git a/DB.py b/DB.py index 2fd72e4..fd49a4b 100644 --- a/DB.py +++ b/DB.py @@ -286,6 +286,9 @@ class DBVidcon: logger.info("[Redis l2 pop error]", e) self.reconnect_redis() items = [] + if items: + return items, 2 + logger.info("[Redis queues empty] 所有队列均为空") return items, 99 @redis_retry(max_retries=3)