EFC/microservice
5
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

solucion tarea acuse #5

Merged
jcedilloAS merged 1 commits from asuses-update into main 2026-03-27 14:30:29 +00:00
Conversation 0 Commits 1 Files Changed 1 +17 -11
1 changed files with 17 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
api/api_v2/modules/acuses/tasks.py
View File

@@ -20,9 +20,11 @@ def process_acuse_request(self, acuse_request: Dict[str, Any]) -> Dict[str, Any]
organizacion_id = pedimento_info.get('organizacion') organizacion_id = pedimento_info.get('organizacion')
pedimento_app = pedimento_info.get('pedimento_app', 'N/A') pedimento_app = pedimento_info.get('pedimento_app', 'N/A')
loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
try: try:
# Registrar el inicio de la tarea # Registrar el inicio de la tarea
loop = asyncio.get_event_loop()
logging.info(f"[ACUSE] Registrando inicio de tarea {task_id}") logging.info(f"[ACUSE] Registrando inicio de tarea {task_id}")
loop.run_until_complete( loop.run_until_complete(
register_task( 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 # En caso de error, actualizar estado
error_message = f"Error al procesar acuse para pedimento {pedimento_app}: {str(e)}" error_message = f"Error al procesar acuse para pedimento {pedimento_app}: {str(e)}"
logging.error(error_message) logging.error(error_message)
loop.run_until_complete( try:
update_task( loop.run_until_complete(
task_id=task_id, update_task(
status="failed", task_id=task_id,
message=error_message, status="failed",
pedimento_id=pedimento_id, message=error_message,
organizacion_id=organizacion_id, pedimento_id=pedimento_id,
servicio=6 organizacion_id=organizacion_id,
servicio=6
)
) )
) except Exception as update_error:
logging.error(f"Error al actualizar estado de tarea: {update_error}")
raise raise
finally:
loop.close()