Skip to content

Commit 1fa455f

Browse files
onematchfoxclaude
andcommitted
fix(adk): remove redundant X-User-ID headers from session service
The KAgentTokenService event hook now injects X-User-Id on every outgoing request via the ContextVar set in KAgentRequestContextBuilder. The explicit per-call header injections in KAgentSessionService are redundant and were also inconsistently cased (X-User-ID vs X-User-Id). Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> Signed-off-by: Brian Fox <878612+onematchfox@users.noreply.github.com>
1 parent 6750b68 commit 1fa455f

1 file changed

Lines changed: 3 additions & 11 deletions

File tree

python/packages/kagent-adk/src/kagent/adk/_session_service.py

Lines changed: 3 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,6 @@ async def create_session(
4949
response = await self.client.post(
5050
"/api/sessions",
5151
json=request_data,
52-
headers={"X-User-ID": user_id},
5352
)
5453
response.raise_for_status()
5554

@@ -88,10 +87,7 @@ async def get_session(
8887
url += "&limit=-1"
8988

9089
# Make API call to get session
91-
response: httpx.Response = await self.client.get(
92-
url,
93-
headers={"X-User-ID": user_id},
94-
)
90+
response: httpx.Response = await self.client.get(url)
9591
if response.status_code == 404:
9692
return None
9793
response.raise_for_status()
@@ -131,7 +127,7 @@ async def get_session(
131127
@override
132128
async def list_sessions(self, *, app_name: str, user_id: str) -> ListSessionsResponse:
133129
# Make API call to list sessions
134-
response = await self.client.get(f"/api/sessions?user_id={user_id}", headers={"X-User-ID": user_id})
130+
response = await self.client.get(f"/api/sessions?user_id={user_id}")
135131
response.raise_for_status()
136132

137133
data = response.json()
@@ -151,10 +147,7 @@ def list_sessions_sync(self, *, app_name: str, user_id: str) -> ListSessionsResp
151147
@override
152148
async def delete_session(self, *, app_name: str, user_id: str, session_id: str) -> None:
153149
# Make API call to delete session
154-
response = await self.client.delete(
155-
f"/api/sessions/{session_id}?user_id={user_id}",
156-
headers={"X-User-ID": user_id},
157-
)
150+
response = await self.client.delete(f"/api/sessions/{session_id}?user_id={user_id}")
158151
response.raise_for_status()
159152

160153
@override
@@ -172,7 +165,6 @@ async def append_event(self, session: Session, event: Event) -> Event:
172165
response = await self.client.post(
173166
f"/api/sessions/{session.id}/events?user_id={session.user_id}",
174167
json=event_data,
175-
headers={"X-User-ID": session.user_id},
176168
)
177169
response.raise_for_status()
178170

0 commit comments

Comments
 (0)