Update main.py

main.py

@@ -24,25 +24,28 @@ supabase: Client = create_client(url, key)
 @app.post("/send/batch_processing")
 async def testv1(request: Request, background_tasks: BackgroundTasks):
     try:
-        dataset = await request.json()
+        body_data = await request.json()
+
+        print(body_data)
+        # # 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()
+        # }
         
-        # 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()
+        # )
         
-        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'])
+        # # Add processing to background tasks
+        # background_tasks.add_task(process_batch_job, dataset, save_data['batch_job_id'])
+
+        return {'data': 'Batch job is scheduled!'}
         
-        return {'data': 'Batch job is scheduled!', 'batch_job_id': save_data['batch_job_id']},
+        # return {'data': 'Batch job is scheduled!', 'batch_job_id': save_data['batch_job_id']}
            
         
     except Exception as e: