feat: Improves task manager

Author: drorganvidez

app/modules/flamapy/services.py

@@ -10,11 +10,11 @@
 from flamapy.metamodels.fm_metamodel.operations import FMMetrics
 from flamapy.metamodels.pysat_metamodel.operations import PySATMetrics  # noqa
 from flamapy.metamodels.pysat_metamodel.transformations import FmToPysat  # noqa
-from core.managers.task_queue_manager import TaskQueueManager
 from uvl.UVLCustomLexer import UVLCustomLexer
 from uvl.UVLPythonParser import UVLPythonParser
 
 from app.modules.flamapy.repositories import FlamapyRepository
+from core.managers.task_queue_manager import TaskQueueManager
 from core.services.BaseService import BaseService
 
 logger = logging.getLogger(__name__)
@@ -38,11 +38,7 @@ def get_analysis_results(self, fm_model: FeatureModel) -> list[dict[str, Any]]:
         return fm_results
 
     def check_uvl_async(self, filepath: str):
-        task = TaskQueueManager().enqueue_task(
-            "app.modules.flamapy.tasks.check_uvl",
-            filepath=filepath,
-            timeout=5
-        )
+        task = TaskQueueManager().enqueue_task("app.modules.flamapy.tasks.check_uvl", filepath=filepath, timeout=5)
         return {"task_id": task.id}
 
     def check_uvl(self, filepath: str):

app/modules/flamapy/tasks.py

@@ -1,5 +1,6 @@
 from app.modules.flamapy.services import FlamapyService
 
+
 def check_uvl(filepath: str):
     service = FlamapyService()
     return service.check_uvl(filepath)

app/modules/hubfile/routes.py

@@ -72,38 +72,6 @@ def upload_file():
     ext = file.filename.lower().split(".")[-1]
     current_app.logger.info(f"📦 Detected extension: {ext}")
 
-    if ext == "uvl":
-        try:
-            current_app.logger.info("⚙️ Encolando validación UVL async...")
-            task_info = flamapy_service.check_uvl_async(temp_file_path)
-            current_app.logger.info(f"✅ Tarea encolada correctamente: {task_info}")
-            return (
-                jsonify(
-                    {
-                        "message": f"{ext.upper()} uploaded successfully (validation running in background)",
-                        "filename": unique_filename,
-                        "task_id": task_info["task_id"],
-                    }
-                ),
-                202,
-            )
-        except Exception as e:
-            current_app.logger.exception("❌ Error encolando validación UVL")
-            if os.path.exists(temp_file_path):
-                os.remove(temp_file_path)
-                current_app.logger.info(f"🗑️ Archivo temporal eliminado tras fallo: {temp_file_path}")
-            return jsonify({"message": f"Error encolando validación UVL: {str(e)}"}), 500
-
-    elif ext == "zip":
-        current_app.logger.info("📦 ZIP detectado → no se valida, solo se acepta")
-        # Do not validate ZIPs, just accept them
-        pass
-    else:
-        current_app.logger.warning(f"⚠️ Extensión no soportada: {ext}")
-        os.remove(temp_file_path)
-        current_app.logger.info(f"🗑️ Archivo eliminado: {temp_file_path}")
-        return jsonify({"message": "Unsupported file type"}), 400
-
     current_app.logger.info(f"✅ Archivo {unique_filename} aceptado con extensión {ext}")
     return (
         jsonify(

app/modules/zenodo/services.py

@@ -251,8 +251,12 @@ def upload_zip(self, dataset: DataSet, deposition_id: int, zip_path: str) -> dic
             response = requests.post(upload_url, params=self.params, data=data, files=files)
 
         if response.status_code != 201:
-            logger.error(f"Failed to upload ZIP: {response.content}")
-            raise Exception(f"Error uploading ZIP to Zenodo: {response.json()}")
+            logger.error(f"Failed to upload ZIP: {response.status_code} {response.reason}")
+            try:
+                error_payload = response.json()  # Zenodo a veces sí devuelve JSON de error
+            except ValueError:
+                error_payload = response.text  # pero si no, mostramos el HTML/texto plano
+            raise Exception(f"Error uploading ZIP to Zenodo: {error_payload}")
 
         return response.json()
 

core/managers/task_queue_manager.py

@@ -47,4 +47,4 @@ def enqueue_task(self, task_name: str, *args, timeout=None, **kwargs):
         job = self.queue.enqueue(task_name, *args, **kwargs, job_timeout=timeout)
         logger.info(f"Task '{task_name}' enqueued with id={job.id}, args={args}, kwargs={kwargs}, timeout={timeout}")
 
-        return job
+        return job