Update app.py

app.py

@@ -29,22 +29,16 @@ async def process_omr(
     omr_marker: UploadFile = File(...),
     pdf_file: UploadFile = File(...),
 ):
-    """
-    Receives OMR-related files, processes them, and returns the analysis results.
-    """
 
-    print("🔹 [START] Processing new OMR request...")
 
     try:
-        # Clear old input/output data
-        print("🧹 Cleaning old directories...")
+        print("Cleaning old directories...")
         shutil.rmtree(INPUT_DIR, ignore_errors=True)
         shutil.rmtree(OUTPUT_DIR, ignore_errors=True)
         os.makedirs(INPUT_DIR, exist_ok=True)
         os.makedirs(OUTPUT_DIR, exist_ok=True)
 
-        # Save uploaded files
-        print("💾 Saving uploaded files to INPUT_DIR...")
+        print("Saving uploaded files to INPUT_DIR...")
         uploaded_files = {
             "config.json": config,
             "evaluation.json": evaluation,
@@ -59,8 +53,7 @@ async def process_omr(
                 shutil.copyfileobj(file.file, buffer)
             print(f"✅ Saved: {filename}")
 
-        # Convert PDF to images
-        print("📄 Converting PDF to images...")
+        print("Converting PDF to images...")
         pdf_path = os.path.join(INPUT_DIR, pdf_file.filename)
         images = convert_from_path(pdf_path)
         image_paths = []
@@ -72,8 +65,6 @@ async def process_omr(
             image_paths.append(img_output_path)
             print(f"🖼️ Converted and saved: {img_output_path}")
 
-        # Run main.py as subprocess
-        print("🚀 Running main.py with subprocess...")
         script_path = os.path.join(os.path.dirname(__file__), "main.py")
 
         process = subprocess.run(
@@ -82,16 +73,12 @@ async def process_omr(
             text=True,
         )
 
-        print("📜 Subprocess stdout:")
         print(process.stdout)
-        print("⚠️ Subprocess stderr:")
         print(process.stderr)
 
-        # Expected output files
         response_json = os.path.join(OUTPUT_DIR, "read_response.json")
         score_txt = os.path.join(OUTPUT_DIR, "score.txt")
 
-        # Collect outputs
         results = {"converted_images": [], "read_response": None, "score": None}
 
         output_images = [
@@ -107,17 +94,17 @@ async def process_omr(
         if os.path.exists(response_json):
             with open(response_json, "r") as f:
                 results["read_response"] = json.load(f)
-            print("✅ Loaded read_response.json")
+            print("Loaded read_response.json")
 
         if os.path.exists(score_txt):
             with open(score_txt, "r") as f:
                 results["score"] = f.read().strip()
-            print("✅ Loaded score.txt")
+            print("Loaded score.txt")
 
-        print("🎉 [SUCCESS] Processing complete.")
+        print("Processing complete.")
         return JSONResponse(content=results)
 
     except Exception as e:
-        print("❌ [ERROR] Exception during OMR processing:")
+        print("Exception during OMR processing:")
         traceback.print_exc()
         return JSONResponse(content={"error": str(e)}, status_code=500)