|
|
@@ -43,7 +43,7 @@ class RedisQueue:
|
|
|
# 序列化任务参数
|
|
|
tasks = [json.dumps(t, default=lambda obj: obj.__dict__['data']) for t in tasks]
|
|
|
if allow_output_log:
|
|
|
- logger.info(f'RedisQueue info > the number of push tasks: {len(tasks)}')
|
|
|
+ logger.debug(f'RedisQueue info > the number of push tasks: {len(tasks)}')
|
|
|
|
|
|
if not tasks:
|
|
|
return self.get_len(key)
|
|
|
@@ -93,7 +93,7 @@ class RedisQueue:
|
|
|
"""
|
|
|
tasks = [json.dumps(t, default=lambda obj: obj.__dict__['data']) for t in tasks]
|
|
|
if allow_output_log:
|
|
|
- logger.info(f'RedisQueue info > the number of push tasks: {len(tasks)}')
|
|
|
+ logger.debug(f'RedisQueue info > the number of push tasks: {len(tasks)}')
|
|
|
if not tasks:
|
|
|
return self.redis.llen(key)
|
|
|
|
