From f9139c980a0da19f33117a5f7bc2b3d0de6bc69d Mon Sep 17 00:00:00 2001
From: Dulce <dmaldonado@aduanasoft.com.mx>
Date: Fri, 27 Mar 2026 08:25:43 -0600
Subject: [PATCH] solucion tarea acuse

---
 api/api_v2/modules/acuses/tasks.py | 28 +++++++++++++++++-----------
 1 file changed, 17 insertions(+), 11 deletions(-)

diff --git a/api/api_v2/modules/acuses/tasks.py b/api/api_v2/modules/acuses/tasks.py
index 9559166..4b2e052 100644
--- a/api/api_v2/modules/acuses/tasks.py
+++ b/api/api_v2/modules/acuses/tasks.py
@@ -20,9 +20,11 @@ def process_acuse_request(self, acuse_request: Dict[str, Any]) -> Dict[str, Any]
     organizacion_id = pedimento_info.get('organizacion')
     pedimento_app = pedimento_info.get('pedimento_app', 'N/A')
     
+    loop = asyncio.new_event_loop()
+    asyncio.set_event_loop(loop)
+    
     try:
         # Registrar el inicio de la tarea
-        loop = asyncio.get_event_loop()
         logging.info(f"[ACUSE] Registrando inicio de tarea {task_id}")
         loop.run_until_complete(
             register_task(
@@ -73,15 +75,19 @@ def process_acuse_request(self, acuse_request: Dict[str, Any]) -> Dict[str, Any]
         # En caso de error, actualizar estado
         error_message = f"Error al procesar acuse para pedimento {pedimento_app}: {str(e)}"
         logging.error(error_message)
-        loop.run_until_complete(
-            update_task(
-                task_id=task_id,
-                status="failed",
-                message=error_message,
-                pedimento_id=pedimento_id,
-                organizacion_id=organizacion_id,
-                servicio=6
+        try:
+            loop.run_until_complete(
+                update_task(
+                    task_id=task_id,
+                    status="failed",
+                    message=error_message,
+                    pedimento_id=pedimento_id,
+                    organizacion_id=organizacion_id,
+                    servicio=6
+                )
             )
-        )
+        except Exception as update_error:
+            logging.error(f"Error al actualizar estado de tarea: {update_error}")
         raise
-
+    finally:
+        loop.close()
\ No newline at end of file