Update app.py

app.py

@@ -174,10 +174,14 @@ def process_chunk_sync(agent, chunk: str, chunk_idx: int) -> Tuple[int, str]:
         return chunk_idx, ""
 
 async def process_file(agent: TxAgent, file_path: str) -> Generator[Tuple[List[Dict[str, str]], Union[str, None]], None, None]:
-    """Process the file with improved error handling and vLLM stability"""
     messages = []
     report_path = None
     
+    if file_path is None:
+        messages.append({"role": "assistant", "content": "❌ Please upload a valid Excel file before analyzing."})
+        yield messages, None
+        return
+
     try:
         # Initial messages
         messages.append({"role": "user", "content": f"Processing file: {os.path.basename(file_path)}"})
@@ -191,13 +195,13 @@ async def process_file(agent: TxAgent, file_path: str) -> Generator[Tuple[List[D
         messages.append({"role": "assistant", "content": f"✅ Extracted {len(chunks)} chunks in {time.time()-start_time:.1f}s"})
         yield messages, None
         
-        # Process chunks sequentially to avoid vLLM socket issues
+        # Process chunks sequentially
         chunk_responses = []
         for idx, chunk in enumerate(chunks):
             messages.append({"role": "assistant", "content": f"🔍 Processing chunk {idx+1}/{len(chunks)}..."})
             yield messages, None
             
-            _, response = process_chunk_sync(agent, chunk, idx)
+            _, response = await process_chunk(agent, chunk, idx)
             chunk_responses.append(response)
             
             messages.append({"role": "assistant", "content": f"✅ Chunk {idx+1} processed"})
@@ -245,7 +249,6 @@ async def process_file(agent: TxAgent, file_path: str) -> Generator[Tuple[List[D
         logger.error(f"Processing failed: {str(e)}")
         messages.append({"role": "assistant", "content": f"❌ Error: {str(e)}"})
         yield messages, None
-
 def create_ui(agent: TxAgent):
     """Create the Gradio interface with simplified interaction"""
     with gr.Blocks(title="Clinical Analysis", css=".gradio-container {max-width: 900px}") as demo:
@@ -275,7 +278,7 @@ def create_ui(agent: TxAgent):
                 )
         
         analyze_btn.click(
-            fn=lambda file: process_file(agent, file.name) if file else ([{"role": "assistant", "content": "❌ Please upload a file"}], None),
+            fn=lambda file: process_file(agent, file.name if file else None),
             inputs=[file_input],
             outputs=[chatbot, report_output],
             concurrency_limit=1  # Ensure sequential processing