Update app.py

app.py

@@ -257,6 +257,10 @@ async def run_with_heartbeat(websocket, blocking_fn, *args, status, detail, max_
             elapsed += HEARTBEAT_SEC
             if elapsed >= max_seconds:
                 task.cancel()
+                try:
+                    await task
+                except (asyncio.CancelledError, Exception):
+                    pass
                 raise ProcessingTimeout(
                     f"مرحله‌ی «{detail}» بیشتر از {max_seconds} ثانیه طول کشید و متوقف شد."
                 )