Commitce4dbe3

committed

feat: support oauth for sse

1 parente84053a commitce4dbe3Copy full SHA for ce4dbe3

File tree

-2

lines changed

-2

lines changed

Lines changed: 5 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -728,6 +728,7 @@ def _http_get_client(`
`728`	`728`	`timeout=timeout,`
`729`	`729`	`httpx_client_factory=self._httpx_client_factory,`
`730`	`730`	`sse_read_timeout=sse_read_timeout,`
	`731`	`+auth=auth,`
`731`	`732`	`)`
`732`	`733`	`ifself.config.transportin ("streamable"):`
`733`	`734`	`returnstreamablehttp_client(`
`@@ -1013,8 +1014,10 @@ def auth_manager(self) -> OAuthManager:`
`1013`	`1014`
`1014`	`1015`	`asyncdefcreate_oauth_authorization(self)->AuthorizationProgress:`
`1015`	`1016`	`"""Authorize the OAuth client."""`
`1016`		`-ifself.config.transport!="streamable":`
`1017`		`-raiseRuntimeError("Only streamable transport is supported for oauth")`
	`1017`	`+ifself.config.transport!="streamable"andself.config.transport!="sse":`
	`1018`	`+raiseRuntimeError(`
	`1019`	`+"Only streamable and sse transport is supported for oauth"`
	`1020`	`+ )`
`1018`	`1021`
`1019`	`1022`	`ifself.auth_managerisNone:`
`1020`	`1023`	`raiseRuntimeError("OAuth manager is not initialized")`

Comments

(0)