Update app.py

app.py

@@ -198,10 +198,11 @@ async def process_file(agent: TxAgent, file_path: str) -> Generator[Tuple[List[D
         with ThreadPoolExecutor(max_workers=MAX_CONCURRENT) as executor:
             futures = []
             for idx, chunk in enumerate(chunks):
-                futures.append(executor.submit(
+                future = executor.submit(
                     lambda c, i: asyncio.run(process_chunk(agent, c, i)),
                     chunk, idx
                 )
+                futures.append(future)
                 messages.append({"role": "assistant", "content": f"🔍 Processing chunk {idx+1}/{len(chunks)}..."})
                 yield messages, None