refactor: make wrapper kw-only across all session implementations

Apply consistent kw-only enforcement for the wrapper parameter in
get_items() and add_items() across all built-in and extension session
implementations:

- src/agents/memory/session.py (SessionABC + NullSession)
- src/agents/memory/sqlite_session.py
- src/agents/memory/openai_responses_compaction_session.py
- src/agents/memory/openai_conversations_session.py
- src/agents/extensions/memory/async_sqlite_session.py
- src/agents/extensions/memory/advanced_sqlite_session.py
- src/agents/extensions/memory/encrypt_session.py
- src/agents/extensions/memory/redis_session.py
- src/agents/extensions/memory/dapr_session.py
- src/agents/extensions/memory/sqlalchemy_session.py
- examples/memory/file_session.py

Author: HuxleyHu98

examples/memory/file_session.py

@@ -47,6 +47,7 @@ async def get_session_id(self) -> str:
     async def get_items(
         self,
         limit: int | None = None,
+        *,
         wrapper: RunContextWrapper[Any] | None = None,
     ) -> list[Any]:
         session_id = await self._ensure_session_id()
@@ -58,6 +59,7 @@ async def get_items(
     async def add_items(
         self,
         items: list[Any],
+        *,
         wrapper: RunContextWrapper[Any] | None = None,
     ) -> None:
         if not items:

src/agents/extensions/memory/advanced_sqlite_session.py

@@ -126,6 +126,7 @@ def _init_structure_tables(self):
     async def add_items(
         self,
         items: list[TResponseInputItem],
+        *,
         wrapper: RunContextWrapper[Any] | None = None,
     ) -> None:
         """Add items to the session.
@@ -143,8 +144,8 @@ async def add_items(
     async def get_items(
         self,
         limit: int | None = None,
-        wrapper: RunContextWrapper[Any] | None = None,
         *,
+        wrapper: RunContextWrapper[Any] | None = None,
         branch_id: str | None = None,
     ) -> list[TResponseInputItem]:
         """Get items from current or specified branch.

src/agents/extensions/memory/async_sqlite_session.py

@@ -106,6 +106,7 @@ async def _locked_connection(self) -> AsyncIterator[aiosqlite.Connection]:
     async def get_items(
         self,
         limit: int | None = None,
+        *,
         wrapper: RunContextWrapper[Any] | None = None,
     ) -> list[TResponseInputItem]:
         """Retrieve the conversation history for this session.
@@ -158,6 +159,7 @@ async def get_items(
     async def add_items(
         self,
         items: list[TResponseInputItem],
+        *,
         wrapper: RunContextWrapper[Any] | None = None,
     ) -> None:
         """Add new items to the conversation history.

src/agents/extensions/memory/dapr_session.py

@@ -237,6 +237,7 @@ async def _handle_concurrency_conflict(self, error: Exception, attempt: int) ->
     async def get_items(
         self,
         limit: int | None = None,
+        *,
         wrapper: RunContextWrapper[Any] | None = None,
     ) -> list[TResponseInputItem]:
         """Retrieve the conversation history for this session.
@@ -280,6 +281,7 @@ async def get_items(
     async def add_items(
         self,
         items: list[TResponseInputItem],
+        *,
         wrapper: RunContextWrapper[Any] | None = None,
     ) -> None:
         """Add new items to the conversation history.