🐞 fix:

uplion · Jul 16, 2024 · 3439def · 3439def
1 parent 656e3d1
commit 3439def
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/WorkerNodePython/WorkerNode/WorkerNode.py b/WorkerNodePython/WorkerNode/WorkerNode.py
@@ -166,7 +166,7 @@ def run(self):
                 continue
             except json.JSONDecodeError as e:
                 if msg:
-                    self.consumer.negative_acknowledge(msg)
+                    self.consumer.acknowledge(msg)
             except requests.exceptions.HTTPError as e:
                 # 处理 HTTP 错误
                 if e.response.status_code == 401:
@@ -199,12 +199,12 @@ def run(self):
                     print('error status code: {}'.format(e.response.status_code))
                     Event.createEvent(apiInstance,AIModelName,AIModelNamespace,'GeneralError',error_detail['error']['message'])
                 if msg:
-                    self.consumer.negative_acknowledge(msg)
+                    self.consumer.acknowledge(msg)
 
             except Exception as e:
                 print(e.__str__())
                 if msg:
-                    self.consumer.negative_acknowledge(msg)
+                    self.consumer.acknowledge(msg)
 
             finally:
                 queue.task_done()