Update main.py

main.py

@@ -22,14 +22,11 @@ client = Client(api_key=os.getenv('OPENAI_API_KEY'),organization=os.getenv('ORG_
 async def batch_processing_result(request: Request, background_tasks: BackgroundTasks):
     body = await request.json()
     batch_id = body.get('batch_job_id')
-    batch_job = client.batches.retrieve(batch_id)
-    # while batch_job.status == 'in_progress':
-    batch_job = client.batches.retrieve(batch_id)
-    print(batch_job.status)
+
     # Add the processing task to background tasks
-    if batch_job.status == 'completed':
-        background_tasks.add_task(process_batch_data, batch_id)
-        return {"batch_job_status":'completed'} 
+    # if batch_job.status == 'completed':
+    #     background_tasks.add_task(process_batch_data, batch_id)
+    #     return {"batch_job_status":'completed'} 
     
     # Immediately return success response
     return {'batch_job_status':'notcompleted'}