Update ack

worker.py

@@ -74,6 +74,7 @@ class RabbitMQWorker:
 
         try:
             if headers.get("request_type") == "process_files":
+                ch.basic_ack(delivery_tag=method.delivery_tag)
                 contexts = []
                 body_dict = json.loads(body)
                 
@@ -87,7 +88,7 @@ class RabbitMQWorker:
                         contexts.append({"key": file["key"], "body": f"Error: {str(e)}"})
 
                 body_dict["md_context"] = contexts
-                ch.basic_ack(delivery_tag=method.delivery_tag)
+                
                 
                 # Publish results
                 if self.publish_message(body_dict, headers):
@@ -98,7 +99,7 @@ class RabbitMQWorker:
                 
                 print(f"[Worker {thread_id}] Contexts: {contexts}")
             else:
-                ch.basic_nack(delivery_tag=method.delivery_tag, requeue=True)
+                ch.basic_ack(delivery_tag=method.delivery_tag)
                 print(f"[Worker {thread_id}] Unknown process")
                 
         except Exception as e: