Browse Source

redis 返回 retry 加入 int()

visuddhinanda 9 months ago
parent
commit
d9bb5e106a
1 changed files with 2 additions and 3 deletions
  1. 2 3
      ai-translate/ai_translate/worker.py

+ 2 - 3
ai-translate/ai_translate/worker.py

@@ -28,9 +28,8 @@ def handle_message(redis, ch, method, id, content_type, body, api_url: str, cust
     except Exception as e:
         # retry
         retryKey = f'{redis[1]}/message/retry/{id}'
-        retry: int = 0
-        if redis[0].exists(retryKey):
-            retry = redis[0].get(retryKey)
+        retry = int(redis[0].get(retryKey)
+                    or 0) if redis[0].exists(retryKey) else 0
         if retry > MaxRetry:
             logger.error(f'超过最大重试次数[{MaxRetry}],任务失败')
             # NACK 丢弃或者进入死信队列