upload de projetos funcional + busca por bpm

scripts/handler/main.py

@@ -217,7 +217,7 @@ def main_parallel():
     log_system_info()
     logging.info("=== Iniciando Pipeline Otimizado ===")
 
-    #create_folders_if_not_exist([MMPZ_FOLDER, WAV_FOLDER, METADATA_FOLDER, DATA_FOLDER])
+    create_folders_if_not_exist([MMPZ_FOLDER, WAV_FOLDER, METADATA_FOLDER, DATA_FOLDER])
 
     if not os.path.exists(MMP_FOLDER):
         logging.critical(f"Pasta {MMP_FOLDER} não encontrada.")
@@ -232,16 +232,16 @@ def main_parallel():
     num_cores = multiprocessing.cpu_count()
     logging.info(f"Processando {len(all_files)} arquivos com {num_cores} workers.")
 
-    #with multiprocessing.Pool(processes=num_cores) as pool:
-    #    results = pool.map(process_single_file, all_files)
+    with multiprocessing.Pool(processes=num_cores) as pool:
+        results = pool.map(process_single_file, all_files)
 
     # Processamento de resultados (igual ao seu)
-    #successful_data = [r["data"] for r in results if r["success"]]
-    #failed_files = [r for r in results if not r["success"]]
+    successful_data = [r["data"] for r in results if r["success"]]
+    failed_files = [r for r in results if not r["success"]]
 
-    #if successful_data:
-    #    save_to_json(successful_data, os.path.join(METADATA_FOLDER, "all.json"))
-    #    save_to_yaml(successful_data, os.path.join(DATA_FOLDER, "all.yml"))
+    if successful_data:
+        save_to_json(successful_data, os.path.join(METADATA_FOLDER, "all.json"))
+        save_to_yaml(successful_data, os.path.join(DATA_FOLDER, "all.yml"))
 
     # Geração de Manifestos
     try:
@@ -250,16 +250,16 @@ def main_parallel():
         manifest_report = {"generated": [], "failed": [str(e)]}
 
     # Relatório Final
-    #duration = time.time() - start_time
-    #logging.info("=" * 60)
-    #logging.info(
-    #    f"FIM - Tempo: {duration:.2f}s | Sucessos: {len(successful_data)} | Falhas: {len(failed_files)}"
-    #)
+    duration = time.time() - start_time
+    logging.info("=" * 60)
+    logging.info(
+        f"FIM - Tempo: {duration:.2f}s | Sucessos: {len(successful_data)} | Falhas: {len(failed_files)}"
+    )
 
-    #if failed_files:
-    #    logging.info("--- Detalhe das Falhas ---")
-    #    for f in failed_files:
-    #        logging.error(f"{f['file']}: {f['error']}")
+    if failed_files:
+        logging.info("--- Detalhe das Falhas ---")
+        for f in failed_files:
+            logging.error(f"{f['file']}: {f['error']}")
 
     # Verificação de Dependências (Projetos)
     try: