Fix: missed EOF markup (#120)

* Fix: missed EOF markup

* Fix: resource release

* Fix: cleanup

Author: JohnRichard4096

pyproject.toml

@@ -8,8 +8,8 @@ dependencies = [
     "aiofiles>=25.1.0",
     "aiohttp>=3.13.3",
     "aiologic>=0.16.0",
-    "amrita-sense>=0.4.3",
-    "fastmcp>=3.2.0",        # Updated, see https://github.com/advisories/GHSA-rww4-4w9c-7733 for details.
+    "amrita-sense>=0.4.5.1",
+    "fastmcp-slim[client]>=3.4.4",
     "filetype>=1.2.0",
     "importlib>=1.0.4",
     "jinja2>=3.1.6",

src/amrita_core/chatmanager/chat_object.py

@@ -577,6 +577,13 @@ async def _entry(self) -> None:
             finally:
                 self._is_running = False
                 self._is_done = True
+                try:
+                    await self.io_stream.set_queue_done()  # Write a EOF to the queue
+                except TimeoutError:
+                    logger.warning(
+                        "Timeout while writing EOF to the queue, force overwrite."
+                    )
+                    self.io_stream._queue_done = True
                 self.end_at = datetime.now(utc)
                 self._chatman.running_chat_object_id2map.pop(self.stream_id, None)  # type: ignore[arg-type]
                 if self._chatman.clean_obj(