Update main.py

main.py

@@ -20,6 +20,36 @@ url: str = os.getenv('SUPABASE_URL')
 key: str = os.getenv('SUPABASE_KEY')
 supabase: Client = create_client(url, key)
 
+
+@app.post("/send/batch_processing")
+async def testv1(request: Request, background_tasks: BackgroundTasks):
+    try:
+        dataset = await request.json()
+        
+        # Create initial batch job record
+        save_data = {
+            'batch_job_id': f"batch_{datetime.utcnow().strftime('%Y%m%d_%H%M%S')}",
+            "batch_job_status": False,
+            "created_at": datetime.utcnow().isoformat()
+        }
+        
+        response = (
+            supabase.table("batch_processing_details")
+            .insert(save_data)
+            .execute()
+        )
+        
+        # Add processing to background tasks
+        background_tasks.add_task(process_batch_job, dataset, save_data['batch_job_id'])
+        
+        return {'data': 'Batch job is scheduled!', 'batch_job_id': save_data['batch_job_id']},
+           
+        
+    except Exception as e:
+        return {'error': str(e)}
+
+
+
 async def process_batch_job(dataset: Dict[str, Any], batch_job_id: str):
     """
     Background task to process the batch job
@@ -101,31 +131,3 @@ async def process_batch_job(dataset: Dict[str, Any], batch_job_id: str):
             "error": str(e),
             "completed_at": datetime.utcnow().isoformat()
         }).eq({"batch_job_id": batch_job_id}).execute()
-
-@app.post("/test/v1")
-async def testv1(request: Request, background_tasks: BackgroundTasks):
-    try:
-        dataset = await request.json()
-        
-        # Create initial batch job record
-        save_data = {
-            'batch_job_id': f"batch_{datetime.utcnow().strftime('%Y%m%d_%H%M%S')}",
-            "batch_job_status": False,
-            "created_at": datetime.utcnow().isoformat()
-        }
-        
-        response = (
-            supabase.table("batch_processing_details")
-            .insert(save_data)
-            .execute()
-        )
-        
-        # Add processing to background tasks
-        background_tasks.add_task(process_batch_job, dataset, save_data['batch_job_id'])
-        
-        return {'data': 'Batch job is scheduled!', 'batch_job_id': save_data['batch_job_id']},
-           
-        
-    except Exception as e:
-        return {'error': str(e)}
-