diff --git a/api/api_v2/modules/acuses/services.py b/api/api_v2/modules/acuses/services.py index f0d71bf..b9d843b 100644 --- a/api/api_v2/modules/acuses/services.py +++ b/api/api_v2/modules/acuses/services.py @@ -84,7 +84,7 @@ async def obtener_acuse(**kwargs): async def change_edocument_status(edoc: dict, status: bool, pedimento: dict): data = { "id": edoc.get("id"), - "edocument_descargado": status, + "acuse_descargado": status, "numero_edocument": edoc.get("numero_edocument"), "pedimento": pedimento.get("id"), "organizacion": pedimento.get("organizacion"), diff --git a/api/api_v2/modules/acuses/tasks.py b/api/api_v2/modules/acuses/tasks.py index ae47aca..9e05ab1 100644 --- a/api/api_v2/modules/acuses/tasks.py +++ b/api/api_v2/modules/acuses/tasks.py @@ -20,8 +20,20 @@ def process_acuse_request(acuse_request: Dict[str, Any]) -> Dict[str, Any]: Returns: Diccionario con la respuesta del acuse. """ - loop = asyncio.get_event_loop() - acuse_response = loop.run_until_complete(obtener_acuse(**acuse_request)) - - return {"status": "processed", "data": acuse_response} + try: + # Crear un nuevo event loop para esta tarea + loop = asyncio.new_event_loop() + asyncio.set_event_loop(loop) + + # Ejecutar la corutina + acuse_response = loop.run_until_complete(obtener_acuse(**acuse_request)) + + return {"status": "processed", "data": acuse_response} + except Exception as e: + logging.error(f"Error processing acuse request: {str(e)}") + raise + finally: + # Asegurarse de cerrar el loop y limpiarlo + loop.close() + asyncio.set_event_loop(None) diff --git a/api/api_v2/modules/edocs/services.py b/api/api_v2/modules/edocs/services.py index 3d4060a..869ec6f 100644 --- a/api/api_v2/modules/edocs/services.py +++ b/api/api_v2/modules/edocs/services.py @@ -151,7 +151,7 @@ async def obtener_edoc(**kwargs): async def change_edocument_status(edoc: dict, status: bool, pedimento: dict): data = { "id": edoc.get("id"), - "acuse_descargado": status, + "edocument_descargado": status, "numero_edocument": edoc.get("numero_edocument"), "pedimento": pedimento.get("id"), "organizacion": pedimento.get("organizacion"),