diff --git a/changelog/4028.changed.md b/changelog/4028.changed.md
new file mode 100644
index 000000000..56d5d2f17
--- /dev/null
+++ b/changelog/4028.changed.md
@@ -0,0 +1 @@
+- Modeified `InworldTTSService` to close context at end of turn instead of relying on idle timeout
diff --git a/src/pipecat/services/inworld/tts.py b/src/pipecat/services/inworld/tts.py
index dc09c0481..06babc99f 100644
--- a/src/pipecat/services/inworld/tts.py
+++ b/src/pipecat/services/inworld/tts.py
@@ -774,14 +774,20 @@ class InworldTTSService(WebsocketTTSService):
         self._cumulative_time = 0.0
         self._generation_end_time = 0.0
 
+    async def on_turn_context_completed(self):
+        """Close the server-side context at end of turn.
+
+        Sends close_context so contextClosed arrives immediately after the
+        last audio byte.
+        """
+        ctx_id = self._turn_context_id
+        await super().on_turn_context_completed()
+        await self._close_context(ctx_id)
+
     async def on_audio_context_interrupted(self, context_id: str):
         """Callback invoked when an audio context has been interrupted."""
         await self._close_context(context_id)
 
-    async def on_audio_context_completed(self, context_id: str):
-        """Callback invoked when an audio context has been completed."""
-        await self._close_context(context_id)
-
     def _get_websocket(self):
         """Get the websocket for the Inworld WebSocket TTS service.