Update extract_insights.py

extract_insights.py

@@ -18,24 +18,24 @@ key: str = os.getenv('SUPABASE_KEY')
 supabase: Client = create_client(url, key)
 
 
-@app.post("/send/synchronous_processing")
-async def testv1(request: Request, background_tasks: BackgroundTasks):
-    try:
-        body_data = await request.json()
-        user_id = body_data.get("user_id")
-        email = body_data.get("email")
-        message_id = body_data.get("message_id")
-        raw_text = body_data.get("raw_text")
+# @app.post("/send/synchronous_processing")
+# async def testv1(request: Request, background_tasks: BackgroundTasks):
+#     try:
+#         body_data = await request.json()
+#         user_id = body_data.get("user_id")
+#         email = body_data.get("email")
+#         message_id = body_data.get("message_id")
+#         raw_text = body_data.get("raw_text")
 
-        # Add processing to background tasks
-        background_tasks.add_task(process_synchronous_job, user_id,email,message_id,raw_text)
+#         # Add processing to background tasks
+#         background_tasks.add_task(process_synchronous_job, user_id,email,message_id,raw_text)
 
-        return {'data': 'Batch job is scheduled!'}
+#         return {'data': 'Batch job is scheduled!'}
         
            
         
-    except Exception as e:
-        return {'error': str(e)}
+#     except Exception as e:
+#         return {'error': str(e)}
 
 
 # def receipt_radar_prompt(raw_text:str)->str: