Create app.py

app.py

@@ -0,0 +1,73 @@
+from flask import Flask, render_template, request, jsonify
+from processor import DatasetCommandCenter
+import threading
+import uuid
+
+app = Flask(__name__)
+
+# In-memory storage for job status (Use Redis for production)
+jobs = {}
+
+@app.route('/')
+def index():
+    return render_template('index.html')
+
+@app.route('/inspect', methods=['POST'])
+def inspect():
+    data = request.json
+    token = data.get('token')
+    dataset_id = data.get('dataset_id')
+    split = data.get('split', 'train')
+    
+    center = DatasetCommandCenter(token=token)
+    result = center.inspect_dataset(dataset_id, split=split)
+    return jsonify(result)
+
+@app.route('/preview', methods=['POST'])
+def preview():
+    data = request.json
+    token = data.get('token')
+    dataset_id = data.get('dataset_id')
+    split = data.get('split', 'train')
+    recipe = data.get('recipe', {})
+    
+    center = DatasetCommandCenter(token=token)
+    try:
+        preview_rows = center.preview_transform(dataset_id, split, recipe)
+        return jsonify({"status": "success", "rows": preview_rows})
+    except Exception as e:
+        return jsonify({"status": "error", "message": str(e)})
+
+@app.route('/execute', methods=['POST'])
+def execute():
+    data = request.json
+    job_id = str(uuid.uuid4())
+    
+    token = data.get('token')
+    source_id = data.get('dataset_id')
+    target_id = data.get('target_id')
+    split = data.get('split', 'train')
+    recipe = data.get('recipe', {})
+    max_rows = data.get('max_rows')
+
+    # Start background thread
+    def task():
+        center = DatasetCommandCenter(token=token)
+        try:
+            jobs[job_id] = {"status": "running"}
+            res = center.process_and_push(source_id, split, target_id, recipe, max_rows)
+            jobs[job_id] = {"status": "completed", "result": res}
+        except Exception as e:
+            jobs[job_id] = {"status": "failed", "error": str(e)}
+
+    thread = threading.Thread(target=task)
+    thread.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"}))
+
+if __name__ == '__main__':
+    app.run(debug=True, port=7860, host="0.0.0.0")