Update app.py

app.py

@@ -2,6 +2,7 @@ from flask import Flask, render_template, request, jsonify
 from processor import DatasetCommandCenter
 import threading
 import uuid
+import json
 
 app = Flask(__name__)
 jobs = {}
@@ -33,15 +34,36 @@ def inspect_rows():
 @app.route('/preview', methods=['POST'])
 def preview():
     data = request.json
+    recipe = data.get('recipe', {})
+    
+    # DEBUG LOGGING
+    print("="*60)
+    print("PREVIEW REQUEST RECEIVED")
+    print("="*60)
+    print("Dataset:", data.get('dataset_id'))
+    print("Config:", data.get('config'))
+    print("Split:", data.get('split'))
+    print("Recipe:")
+    print(json.dumps(recipe, indent=2))
+    print("="*60)
+    
     center = DatasetCommandCenter(token=data.get('token'))
+    
     try:
-        print(data.get('recipe',{}))
         rows = center.preview_transform(
-            data.get('dataset_id'), data.get('config'), data.get('split'),
-            data.get('recipe', {})
+            data.get('dataset_id'), 
+            data.get('config'), 
+            data.get('split'),
+            recipe
         )
+        
+        print(f"Preview successful: {len(rows)} rows returned")
         return jsonify({"status": "success", "rows": rows})
+        
     except Exception as e:
+        print(f"PREVIEW ERROR: {str(e)}")
+        import traceback
+        traceback.print_exc()
         return jsonify({"status": "error", "message": str(e)})
 
 @app.route('/execute', methods=['POST'])
@@ -58,9 +80,9 @@ def execute():
         data.get('target_id'),
         data.get('recipe', {}),
         data.get('max_rows'),
-        data.get('license') # <--- NEW PARAMETER
+        data.get('license')
     )
-
+    
     def task():
         try:
             jobs[job_id] = {"status": "running"}
@@ -68,11 +90,10 @@ def execute():
             jobs[job_id] = {"status": "completed", "result": res}
         except Exception as e:
             jobs[job_id] = {"status": "failed", "error": str(e)}
-
+    
     threading.Thread(target=task).start()
     return jsonify({"status": "started", "job_id": job_id})
 
-
 @app.route('/status/<job_id>', methods=['GET'])
 def status(job_id):
     return jsonify(jobs.get(job_id, {"status": "unknown"}))