Update app.py

app.py

@@ -2,7 +2,6 @@ from flask import Flask, render_template, request, jsonify
 from processor import DatasetCommandCenter
 import threading
 import uuid
-import os
 
 app = Flask(__name__)
 jobs = {}
@@ -11,65 +10,49 @@ jobs = {}
 def index():
     return render_template('index.html')
 
-# --- Step 1: Analyze Metadata (Configs/Splits) ---
 @app.route('/analyze_metadata', methods=['POST'])
 def analyze_metadata():
     data = request.json
     center = DatasetCommandCenter(token=data.get('token'))
-    result = center.get_dataset_metadata(data.get('dataset_id'))
-    return jsonify(result)
+    return jsonify(center.get_dataset_metadata(data.get('dataset_id')))
 
 @app.route('/get_splits', methods=['POST'])
 def get_splits():
     data = request.json
     center = DatasetCommandCenter(token=data.get('token'))
-    result = center.get_splits_for_config(data.get('dataset_id'), data.get('config'))
-    return jsonify(result)
+    return jsonify(center.get_splits_for_config(data.get('dataset_id'), data.get('config')))
 
-# --- Step 2: Inspect Rows ---
 @app.route('/inspect_rows', methods=['POST'])
 def inspect_rows():
     data = request.json
     center = DatasetCommandCenter(token=data.get('token'))
-    result = center.inspect_dataset(
-        data.get('dataset_id'), 
-        data.get('config'), 
-        data.get('split')
-    )
-    return jsonify(result)
+    return jsonify(center.inspect_dataset(
+        data.get('dataset_id'), data.get('config'), data.get('split')
+    ))
 
-# --- Step 3: Preview Transform ---
 @app.route('/preview', methods=['POST'])
 def preview():
     data = request.json
     center = DatasetCommandCenter(token=data.get('token'))
     try:
         rows = center.preview_transform(
-            data.get('dataset_id'), 
-            data.get('config'), 
-            data.get('split'),
+            data.get('dataset_id'), data.get('config'), data.get('split'),
             data.get('recipe', {})
         )
         return jsonify({"status": "success", "rows": rows})
     except Exception as e:
         return jsonify({"status": "error", "message": str(e)})
 
-# --- Step 4: Execute ---
 @app.route('/execute', methods=['POST'])
 def execute():
     data = request.json
     job_id = str(uuid.uuid4())
-    
     token = data.get('token')
     center = DatasetCommandCenter(token=token)
     
     args = (
-        data.get('dataset_id'),
-        data.get('config'),
-        data.get('split'),
-        data.get('target_id'),
-        data.get('recipe', {}),
-        data.get('max_rows')
+        data.get('dataset_id'), data.get('config'), data.get('split'),
+        data.get('target_id'), data.get('recipe', {}), data.get('max_rows')
     )
 
     def task():
@@ -80,9 +63,7 @@ def execute():
         except Exception as e:
             jobs[job_id] = {"status": "failed", "error": str(e)}
 
-    thread = threading.Thread(target=task)
-    thread.start()
-    
+    threading.Thread(target=task).start()
     return jsonify({"status": "started", "job_id": job_id})
 
 @app.route('/status/<job_id>', methods=['GET'])