Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ name = "pipedream"

[tool.poetry]
name = "pipedream"
version = "1.0.10"
version = "1.0.11"
description = ""
readme = "README.md"
authors = []
Expand Down
2 changes: 1 addition & 1 deletion src/pipedream/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
import typing

import httpx
from .types.project_environment import ProjectEnvironment
from ._.types.project_environment import ProjectEnvironment
from .core.api_error import ApiError
from .core.client_wrapper import AsyncClientWrapper, SyncClientWrapper
from .core.oauth_token_provider import OAuthTokenProvider
Expand Down
6 changes: 3 additions & 3 deletions src/pipedream/core/client_wrapper.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
import typing

import httpx
from ..types.project_environment import ProjectEnvironment
from .._.types.project_environment import ProjectEnvironment
from .http_client import AsyncHttpClient, HttpClient


Expand All @@ -27,10 +27,10 @@ def __init__(

def get_headers(self) -> typing.Dict[str, str]:
headers: typing.Dict[str, str] = {
"User-Agent": "pipedream/1.0.10",
"User-Agent": "pipedream/1.0.11",
"X-Fern-Language": "Python",
"X-Fern-SDK-Name": "pipedream",
"X-Fern-SDK-Version": "1.0.10",
"X-Fern-SDK-Version": "1.0.11",
**(self.get_custom_headers() or {}),
}
if self._project_environment is not None:
Expand Down
42 changes: 0 additions & 42 deletions src/pipedream/core/http_sse/__init__.py

This file was deleted.

112 changes: 0 additions & 112 deletions src/pipedream/core/http_sse/_api.py

This file was deleted.

61 changes: 0 additions & 61 deletions src/pipedream/core/http_sse/_decoders.py

This file was deleted.

7 changes: 0 additions & 7 deletions src/pipedream/core/http_sse/_exceptions.py

This file was deleted.

17 changes: 0 additions & 17 deletions src/pipedream/core/http_sse/_models.py

This file was deleted.

24 changes: 20 additions & 4 deletions src/pipedream/oauth_tokens/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,12 @@ def with_raw_response(self) -> RawOauthTokensClient:
return self._raw_client

def create(
self, *, client_id: str, client_secret: str, request_options: typing.Optional[RequestOptions] = None
self,
*,
client_id: str,
client_secret: str,
scope: typing.Optional[str] = OMIT,
request_options: typing.Optional[RequestOptions] = None,
) -> CreateOAuthTokenResponse:
"""
Exchange OAuth credentials for an access token
Expand All @@ -38,6 +43,9 @@ def create(

client_secret : str

scope : typing.Optional[str]
Optional space-separated scopes for the access token. Defaults to '*'.

request_options : typing.Optional[RequestOptions]
Request-specific configuration.

Expand All @@ -62,7 +70,7 @@ def create(
)
"""
_response = self._raw_client.create(
client_id=client_id, client_secret=client_secret, request_options=request_options
client_id=client_id, client_secret=client_secret, scope=scope, request_options=request_options
)
return _response.data

Expand All @@ -83,7 +91,12 @@ def with_raw_response(self) -> AsyncRawOauthTokensClient:
return self._raw_client

async def create(
self, *, client_id: str, client_secret: str, request_options: typing.Optional[RequestOptions] = None
self,
*,
client_id: str,
client_secret: str,
scope: typing.Optional[str] = OMIT,
request_options: typing.Optional[RequestOptions] = None,
) -> CreateOAuthTokenResponse:
"""
Exchange OAuth credentials for an access token
Expand All @@ -94,6 +107,9 @@ async def create(

client_secret : str

scope : typing.Optional[str]
Optional space-separated scopes for the access token. Defaults to '*'.

request_options : typing.Optional[RequestOptions]
Request-specific configuration.

Expand Down Expand Up @@ -126,6 +142,6 @@ async def main() -> None:
asyncio.run(main())
"""
_response = await self._raw_client.create(
client_id=client_id, client_secret=client_secret, request_options=request_options
client_id=client_id, client_secret=client_secret, scope=scope, request_options=request_options
)
return _response.data
Loading
Loading